1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087 |
- <?php
- namespace app\admin\service\order;
- use app\model\CouponDetail;
- use app\model\CouponGoods;
- use app\model\Goods;
- use app\model\GoodsRunning;
- use app\model\GoodsSku;
- use app\model\Member;
- use app\model\MemberBenefit;
- use app\model\Order;
- use app\model\OrderSheet;
- use app\model\PayDetail;
- use app\model\SysDept;
- use support\Db;
- use support\exception\BusinessException;
- use support\Log as SupportLog;
- use support\Redis;
- use Webman\Event\Event;
- use Yansongda\Pay\Exceptions\GatewayException;
- use Yansongda\Pay\Log;
- use Yansongda\Pay\Pay;
- class OrderService
- {
- /**
- * @Desc 自动确认收货
- * @Author Gorden
- * @Date 2024/4/11 16:09
- *
- * @return void
- */
- public static function AutomaticReceipt()
- {
- try {
- Db::beginTransaction();
- $timeUnix = strtotime("-7 days");
- $orders = Order::where('order_status_system', 'SIGNED')
- ->where('order_addtimes', '<', $timeUnix)
- ->get();
- foreach ($orders as $order) {
- // 订单主表
- Order::where('order_id', $order->order_id)->update([
- 'order_is_complete' => 'Y',
- 'order_status_system' => 'CONFIRM',
- 'order_status_storage' => 'DONE'
- ]);
- // 订单详情表
- OrderSheet::where('join_sheet_order_id', $order->order_id)->update(['order_sheet_status' => 'DONE']);
- // 会员升级
- Event::dispatch('order_pay.member_level.up', $order->join_order_member_id);
- // 7天后自动完成 order_is_complete=Y
- // $redis = Redis::connection();
- // $key = Order::AUTOMATIC_COMPLETE_PREFIX . date('Ymd', strtotime("+7 days"));
- // $redis->sadd($key, $order->order_id);
- }
- Db::commit();
- } catch (\Exception $e) {
- Db::rollBack();
- }
- }
- /**
- * @Desc 自动完成订单
- * @Author Gorden
- * @Date 2024/7/16 9:37
- *
- * @return void
- */
- public static function AutomaticComplete()
- {
- Db::beginTransaction();
- try {
- $redis = Redis::connection();
- $key = Order::AUTOMATIC_COMPLETE_PREFIX . date('Ymd');
- $orderIds = $redis->smembers($key);
- foreach ($orderIds as $orderId) {
- $order = Order::where('order_id', $orderId)
- ->select('order_is_complete', 'order_category', 'order_status_system', 'join_order_member_id')
- ->first();
- if ($order && $order->order_is_complete != 'Y' && $order->order_category != 'RETURN' && in_array($order->order_status_system, ['RECVING', 'SIGNED', 'CONFIRM'])) {
- // 更新主表
- Order::where('order_id', $orderId)->update(['order_is_complete' => 'Y', 'order_status_system' => 'CONFIRM', 'order_status_storage' => 'DONE']);
- // sheet表
- OrderSheet::where('join_sheet_order_id', $orderId)->update(['order_sheet_status' => 'DONE']);
- // 会员升级
- Event::dispatch('order_pay.member_level.up', $order->join_order_member_id);
- }
- }
- $redis->del($key);
- Db::commit();
- } catch (\Exception $e) {
- dump($e->getMessage());
- Db::rollBack();
- }
- }
- public static function checkPayingOrder()
- {
- try {
- Db::beginTransaction();
- $timeUnix = strtotime("-30 minutes");
- $orders = Order::where('order_status_system', 'PAYING')
- ->where('order_category', '<>', 'DISHES') // 点餐不自动取消
- ->where('order_category', '<>', 'VIP') // 康养城订单不自动取消,有分次付款
- ->where('order_category', '<>', 'COMBINE') // 新客专享
- ->where('order_category', '<>', 'PARTNER') // 会员合伙人
- ->where('order_category', '<>', 'REFERRER') // 推荐官
- ->where(function ($query) {
- $query->where('order_platform', '<>', 'SYSTEM')->orWhereNull('order_platform');
- })
- ->where('order_addtimes', '<', $timeUnix)
- ->get();
- foreach ($orders as $order) {
- \support\Log::info("取消的订单", ['order_id' => $order->order_id]);
- // 订单主表
- Order::where('order_id', $order->order_id)->update([
- 'order_is_complete' => 'Y',
- 'order_status_system' => 'CANCEL',
- 'order_status_payment' => 'CANCEL'
- ]);
- $sheets = OrderSheet::where('join_sheet_order_id', $order->order_id)->get();
- foreach ($sheets as $sheet) {
- // 还原库存
- $goodsSku = GoodsSku::where('goods_sku_id', $sheet->join_sheet_goods_sku_id)->first();
- if (!empty($goodsSku) && !empty($goodsSku->goods_sku_storage_json)) {
- $skuStorageJson = json_decode($goodsSku->goods_sku_storage_json, true);
- if (isset($skuStorageJson['storage']) && !empty($skuStorageJson['storage'])) {
- $skuStorageJson['storage'] = $skuStorageJson['storage'] + $sheet->order_sheet_num;
- $goodsSku->goods_sku_storage_json = json_encode($skuStorageJson);
- $goodsSku->save();
- }
- }
- $goodsRunning = GoodsRunning::where('join_running_goods_id', $sheet->join_sheet_goods_id)->first();
- if (!empty($goodsRunning)) {
- $goodsRunning->goods_running_storage = $goodsRunning->goods_running_storage + $sheet->order_sheet_num;
- // $goodsRunning->goods_running_sale = $goodsRunning->goods_running_sale - $sheet->order_sheet_num;
- $goodsRunning->save();
- }
- }
- // 释放优惠券
- if (!empty($order->order_discount_json)) {
- $orderDiscountJson = json_decode($order->order_discount_json, true);
- foreach ($orderDiscountJson as $discount) {
- if (!empty($discount['coupon_id']) && !empty($discount['coupon_detail_id'])) {
- foreach ($discount['coupon_detail_id'] as $detailId) {
- if (substr($detailId, 0, 4) == 'CUDT') {
- // 恢复优惠券
- CouponDetail::where('coupon_detail_id', $detailId)->update(['coupon_detail_status' => 'ACTIVED']);
- }
- }
- }
- }
- }
- // 订单详情表
- OrderSheet::where('join_sheet_order_id', $order->order_id)->update(['order_sheet_status' => 'CANCEL']);
- // 支付表
- $payDetail = PayDetail::where('join_pay_order_id', $order->order_groupby)->first();
- if (!empty($payDetail)) {
- $payExtendJson = [];
- if (!empty($payDetail->pay_extend_json)) {
- $payExtendJson = json_decode($payDetail->pay_extend_json, true);
- }
- $payExtendJson['cancel_times'] = date('Y-m-d H:i:s');
- PayDetail::where('join_pay_order_id', $order->order_groupby)->update([
- 'pay_status' => 'CANCEL',
- 'pay_extend_json' => json_encode($payExtendJson)
- ]);
- }
- }
- Db::commit();
- } catch (\Exception $e) {
- \support\Log::error("取消订单失败:" . $e->getMessage());
- Db::rollBack();
- }
- }
- /**
- * @Desc 生成核销数据
- * @Author Gorden
- * @Date 2024/9/9 17:07
- *
- * @param $params
- * @return array
- */
- public static function generateWriteOffData($params)
- {
- return [
- 'charge' => [
- 'charge_amount' => 1,
- 'charge_content' => $params['order_remark'] ?? '',
- 'charge_user_id' => $params['write_off_member_id'],
- 'charge_premises' => $params['dept_premises_id'],
- 'charge_waiter' => $params['charge_waiter'] ?? ''
- ],
- 'member_id' => $params['join_order_member_id']
- ];
- }
- /**
- * @Desc 生成核销数据-入order_process
- * @Author Gorden
- * @Date 2024/9/9 17:07
- *
- * @param $params
- * @return array
- */
- public static function generateWriteOffDataByOrderProcess($params)
- {
- return [
- 'charge' => [
- 'charge_amount' => $params['charge_amount'],
- 'charge_content' => $params['order_remark'] ?? '',
- 'charge_waiter' => $params['charge_waiter'] ?? '',
- 'charge_user_id' => $params['write_off_member_id'],
- 'charge_premises' => $params['dept_premises_id'],
- 'charge_premises_info' => $params['dept'] ?? ''
- ],
- 'member_id' => $params['join_order_member_id'],
- 'goods_id' => $params['goods_id'] ?? '',
- 'goods_sku_id' => $params['goods_sku_id'] ?? '',
- 'order_id' => $params['order_id'],
- 'platform' => 'SYSTEM',
- 'order_code' => random_string(10, 'number'),
- 'appointment' => $params['appointment_ids'] ?? '',
- ];
- }
- public static function generateAppointmentApplyData($params)
- {
- $member = Member::with('cert', 'info')
- ->where('member_id', $params['join_order_member_id'])
- ->first();
- $name = '';
- if (!empty($member) && !empty($member->cert) && !empty($member->cert->member_cert_name)) {
- $name = $member->cert->member_cert_name;
- } else if (!empty($member) && !empty($member->info) && !empty($member->info->member_info_nickname)) {
- $name = $member->info->member_info_nickname;
- }
- return [
- 'name' => $name,
- 'times' => '',
- 'mobile' => !empty($member) ? $member->member_mobile : '',
- 'person' => $params['order_sheet_num'] ?? '',
- 'premises' => $params['dept_premises_id'] ?? ''
- ];
- }
- /**
- * 微信支付宝扫码支付
- */
- public static function qrcodePay($params)
- {
- $log = SupportLog::channel('pay');
- $log->info("PAY_PARAMS", json_decode(json_encode($params), true));
- $params['order_amount_pay'] = floatval($params['order_amount_pay']);
- $qrcodeNbr = $params['qrcode_nbr'];
- $prefix = substr($qrcodeNbr, 0, 2);
- // 模拟数据
- // $result = [
- // 'return_code'=>'SUCCESS',
- // 'result_code' => 'SUCCESS'
- // ];
- // $result=[
- // 'code'=> '10000',
- // 'msg' => 'Success'
- // ];
- // return $result;
- // 微信支付
- if (in_array($prefix, [10, 11, 12, 13, 14, 15])) {
- $payData = [
- 'out_trade_no' => $params['orderGroupId'],
- 'body' => '万悦康养订单',
- 'total_fee' => $params['order_amount_pay'] * 100,
- 'auth_code' => $params['qrcode_nbr'],
- ];
- try {
- $config = config('payment.wxpay');
- $config['notify_url'] = getenv('NOTIFY_DOMAIN_ADMIN') . '/notify/orderPay/wxpay';
- $wxReturn = Pay::wechat($config)->pos($payData);
- $log->info("WXPAY_RETURN", json_decode(json_encode($wxReturn), true));
- $result = self::findWxpay($params['orderGroupId'], 0);
- } catch (GatewayException $g) {
- $result = self::findWxpay($params['orderGroupId'], 0);
- } catch (\Exception $e) {
- $log->error("WXPAY", ['msg' => $e->getMessage()]);
- $result = self::findWxpay($params['orderGroupId'], 0);
- // throw new BusinessException("支付失败");
- }
- try {
- $log->info("WXPAY_RETURN", json_decode(json_encode($result), true));
- } catch (\Exception $e) {
- }
- } else if (in_array($prefix, [25, 26, 27, 28, 29, 30])) {
- $payData = [
- 'out_trade_no' => $params['orderGroupId'],
- 'total_amount' => $params['order_amount_pay'],
- 'subject' => '万悦康养订单',
- 'auth_code' => $params['qrcode_nbr'],
- ];
- try {
- $config = config('payment.alipay');
- $config['notify_url'] = getenv('NOTIFY_DOMAIN_ADMIN') . '/notify/orderPay/alipay';
- $alipayReturn = Pay::alipay($config)->pos($payData);
- $log->info("WXPAY_RETURN", json_decode(json_encode($alipayReturn), true));
- $result = self::findAlipay($params['orderGroupId'], 0);
- } catch (GatewayException $g) {
- $result = self::findAlipay($params['orderGroupId'], 0);
- } catch (\Exception $e) {
- $log->error("ALIPAY", ['msg' => $e->getMessage()]);
- throw new BusinessException("支付失败:" . $e->getMessage());
- // $result['key'] = 'value';
- }
- try {
- $log->info("ALIPAY_RETURN", json_decode(json_encode($result), true));
- } catch (\Exception $e) {
- }
- } else {
- throw new BusinessException("付款码无效");
- }
- return $result;
- }
- /**
- * @Desc 查询微信支付
- * @Author Gorden
- * @Date 2024/8/16 14:55
- *
- * @param $orderId
- * @param $nbr 循环次数
- * @return mixed|void
- * @throws BusinessException
- */
- public static function findWxpay($orderId, $nbr = 0)
- {
- try {
- $result = Pay::wechat(config('payment.wxpay'))->find($orderId, 'pos');
- $result = json_decode(json_encode($result), true);
- SupportLog::channel('pay')->info("FIND_WXPAY_RESULT", $result);
- } catch (\Exception $e) {
- SupportLog::channel('pay')->error("FIND_WXPAY", ['msg' => $e->getMessage()]);
- }
- if (!empty($result['return_code']) && $result['return_code'] == 'SUCCESS' && !empty($result['result_code']) && $result['result_code'] == 'SUCCESS' && !empty($result['trade_state']) && $result['trade_state'] == 'SUCCESS') {
- SupportLog::channel('pay')->info("FIND_WXPAY_SUCCESS", ['nbr' => $nbr, 'order_id' => $orderId]);
- return $result;
- } else {
- if ($nbr > 0) {
- SupportLog::channel('pay')->error("FIND_WXPAY", ['msg' => '订单查询失败', 'order_id' => $orderId]);
- return ['msg' => '订单查询失败'];
- }
- sleep(3);
- SupportLog::channel('pay')->error("FIND_WXPAY", ['nbr' => $nbr, 'order_id' => $orderId]);
- return self::findWxpay($orderId, $nbr + 1);
- }
- }
- /**
- * @Desc 查询支付宝订单
- * @Author Gorden
- * @Date 2024/8/16 15:16
- *
- * @param $orderId
- * @param $nbr 循环次数
- * @return mixed|void
- * @throws BusinessException
- */
- public static function findAlipay($orderId, $nbr = 0)
- {
- try {
- $result = Pay::alipay(config('payment.alipay'))->find($orderId);
- $result = json_decode(json_encode($result), true);
- SupportLog::channel('pay')->info("FIND_ALIPAY_RESULT", $result);
- } catch (\Exception $e) {
- SupportLog::channel('pay')->error("FIND_ALIPAY", ['msg' => $e->getMessage()]);
- }
- if (!empty($result['code']) && $result['code'] == '10000' && !empty($result['trade_status']) && $result['trade_status'] == 'TRADE_SUCCESS') {
- SupportLog::channel('pay')->info("FIND_ALIPAY_SUCCESS", ['nbr' => $nbr, 'order_id' => $orderId]);
- return $result;
- } else {
- if ($nbr > 0) {
- SupportLog::channel('pay')->error("FIND_ALIPAY", ['msg' => '订单查询失败', 'order_id' => $orderId]);
- return ['msg' => '订单查询失败'];
- }
- sleep(3);
- SupportLog::channel('pay')->error("FIND_ALIPAY", ['nbr' => $nbr, 'order_id' => $orderId]);
- return self::findAlipay($orderId, $nbr + 1);
- }
- }
- /**
- * 验证产品库存
- */
- public static function checkGoodsStorage($params)
- {
- foreach ($params['goodsContentList'] as $goods) {
- // 减库存,规格和总库存
- if (!isset($params['submit_goods_classify']) || !in_array($params['submit_goods_classify'], ['MEALS', 'PACKAGE', 'COMBINE'])) {
- $goodsSku = GoodsSku::where('goods_sku_id', $goods['sku_id'])->first();
- $skuStorageJson = json_decode($goodsSku->goods_sku_storage_json, true);
- if (isset($skuStorageJson['storage']) && !empty($skuStorageJson['storage'])) {
- $skuStorageJson['storage'] = $skuStorageJson['storage'] - $goods['nbr'];
- }
- if (!isset($skuStorageJson['storage']) || (!empty($skuStorageJson['storage']) && $skuStorageJson['storage'] < 0)) {
- throw new BusinessException('库存不足');
- }
- }
- $goodsRunning = GoodsRunning::where('join_running_goods_id', $goods['goods_id'])->first();
- $goodsRunning->goods_running_storage = $goodsRunning->goods_running_storage - $goods['nbr'];
- if ($goodsRunning->goods_running_storage < 0) {
- throw new BusinessException('库存不足');
- }
- }
- }
- /**
- * 下单时结算的组合支付payDetail
- */
- public static function createPayDetail($params)
- {
- $insertPayDetailData = [
- 'join_pay_member_id' => $params['join_order_member_id'],
- 'join_pay_order_id' => $params['orderGroupId'],
- 'pay_status' => $params['order_status_payment'] == 'SUCCESS' ? 'SUCCESS' : 'WAITING',
- 'pay_category' => !empty($params['submit_goods_classify']) ? $params['submit_goods_classify'] : $params['goods_classify'],
- 'pay_amount' => $params['order_amount_pay'],
- 'pay_paytimes' => date('Y-m-d H:i:s'),
- 'pay_prepayid' => $params['pay_category'],
- 'pay_json_request' => json_encode($params),
- 'pay_json_response' => $params['pay_json_response'] ?? '[]',
- 'join_pay_object_json' => !empty($params['orderId']) ? json_encode(['order_id' => $params['orderId']]) : '[]',
- 'pay_addtimes' => time()
- ];
- PayDetail::insert($insertPayDetailData);
- }
- /**
- * 组合支付,PayDetail
- */
- public static function createPayConstituteDetail($params, $payDetail)
- {
- $qrcodePrepayId = '';
- if (in_array($params['pay_category'], ['WXPAY', 'ALIPAY'])) {
- $qrcodePrepayId = $params['join_order_member_id'] . '-QRCODE';
- }
- if (!$payDetail || ($payDetail->pay_prepayid != $params['pay_category'] && $payDetail->pay_prepayid != $qrcodePrepayId)) {
- $payDetail = new PayDetail();
- $payDetail->join_pay_member_id = $params['join_order_member_id'];
- $payDetail->join_pay_order_id = $params['orderGroupId'];
- $payDetail->pay_category = $params['goods_classify'] ?? '';
- $payDetail->pay_prepayid = $params['pay_category'];
- $payDetail->pay_json_request = json_encode($params);
- $payDetail->pay_addtimes = time();
- }
- if ($payDetail->pay_prepayid == $qrcodePrepayId) {
- $payDetail->pay_prepayid = $params['pay_category'];
- }
- $payDetail->pay_json_response = $params['pay_json_response'] ?? json_encode([
- 'pay-result' => '支付成功', 'result-datetime' => date('Y-m-d H:i:s')
- ]);
- $payDetail->pay_amount = $params['order_amount_pay'];
- $payDetail->pay_paytimes = date('Y-m-d H:i:s');
- $payDetail->pay_status = 'SUCCESS';
- $payDetail->join_pay_object_json = !empty($params['orderId']) ? json_encode(['order_id' => $params['orderId']]) : '[]';
- $payDetail->save();
- }
- /**
- * 组合支付,PayDetail
- */
- public static function createProductPayConstituteDetail($params)
- {
- $payDetail = new PayDetail();
- $payDetail->join_pay_member_id = $params['join_order_member_id'];
- $payDetail->join_pay_order_id = $params['orderGroupId'];
- $payDetail->pay_category = $params['goods_classify'] ?? '';
- $payDetail->pay_json_request = json_encode($params);
- $payDetail->pay_addtimes = time();
- $payDetail->pay_prepayid = $params['pay_category'];
- $payDetail->pay_json_response = $params['pay_json_response'] ?? json_encode([
- 'pay-result' => '支付成功', 'result-datetime' => date('Y-m-d H:i:s')
- ]);
- $payDetail->pay_amount = $params['order_amount_pay'];
- $payDetail->pay_paytimes = date('Y-m-d H:i:s');
- $payDetail->pay_status = $params['order_status_payment'] == 'SUCCESS' ? 'SUCCESS' : 'WAITING';
- $payDetail->join_pay_object_json = !empty($params['orderId']) ? json_encode(['order_id' => $params['orderId']]) : '[]';
- $payDetail->save();
- }
- public static function getPayWayByPrepayId($prepayId)
- {
- $payWay = '';
- $categoryArray = explode('-', $prepayId);
- if (isset($categoryArray[1])) {
- $payWay = $categoryArray[1];
- } else if (in_array($categoryArray[0], ['WXPAY', 'ALIPAY', 'OFFLINE', 'OFFLINE_ALIPAY', 'OFFLINE_WXPAY', 'MONEY'])) {
- $payWay = $categoryArray[0];
- }
- return $payWay;
- }
- /**
- * @Desc 支付使用优惠券
- * @Author Gorden
- * @Date 2024/8/28 14:59
- *
- * @param $memberId
- * @param $goods
- * @param $coupon
- * @param $payAmount
- * @return array|mixed
- */
- public static function payUseCoupon($type, $settlementNow, $memberId, $goods, $coupon, $payAmount)
- {
- try {
- foreach ($coupon as $item) {
- if (!in_array(substr($item, 0, 2), ['CU', 'CO'])) {
- return [];
- }
- }
- $amountBalance = [
- 'pay_amount' => $payAmount,
- 'welfare_balance' => 0,
- 'cut_balance' => 0,
- ];
- foreach ($goods as $good) {
- $result = OrderService::useCoupon($type, $settlementNow, $memberId, $goods, $good, $coupon, $amountBalance);
- $amountBalance = [
- 'pay_amount' => $result['pay_amount'],
- 'welfare_balance' => $result['welfare_balance'],
- 'cut_balance' => $result['cut_balance'],
- ];
- }
- $couponDetailsIds = Redis::sMembers("ORDER:USE:COUPON:" . $memberId);
- Redis::del("ORDER:USE:COUPON:" . $memberId);
- $useCouponJson = Redis::get("ORDER:USE:COUPON:DISCOUNT:" . $memberId);
- Redis::del("ORDER:USE:COUPON:DISCOUNT:" . $memberId);
- return [
- 'pay_amount' => $amountBalance['pay_amount'],
- 'detail_ids' => $couponDetailsIds,
- 'use_coupon_json' => $useCouponJson ?? []
- ];
- } catch (\Exception $e) {
- dump($e->getTrace());
- }
- }
- public static function useCoupon($type, $settlementNow, $memberId, $goods, $good, $coupon, $amountBalance)
- {
- try {
- $cacheKey = "ORDER:USE:COUPON:" . $memberId;
- $cacheDiscountKey = "ORDER:USE:COUPON:DISCOUNT:" . $memberId;
- $payAmount = $amountBalance['pay_amount'];
- $welfareBalance = $amountBalance['welfare_balance'];
- $cutBalance = $amountBalance['cut_balance'];
- $goodsId = $good['goods_id'];
- $money = $good['goods_sales_price'] * $good['nbr'];
- $discountData = Redis::get($cacheDiscountKey);
- if (empty($discountData)) {
- $discountData = [];
- } else {
- $discountData = json_decode($discountData, true);
- }
- foreach ($coupon as $couponId) {
- $couponDetail = CouponDetail::leftJoin('coupon_goods', 'coupon_goods.join_goods_coupon_id', '=', 'coupon_detail.join_detail_coupon_id')
- ->leftJoin('coupon', 'coupon.coupon_id', '=', 'coupon_detail.join_detail_coupon_id')
- ->select('coupon_detail.coupon_detail_id', 'coupon_goods.coupon_goods_id', 'coupon_id', 'coupon_classify', 'coupon_value', 'coupon_minimum_limit', 'coupon_category')
- ->where('coupon_goods.join_coupon_goods_id', $goodsId)
- // ->where('coupon_goods.join_coupon_goods_sku_id', $good['sku_id'])
- ->where('join_goods_coupon_id', $couponId)
- ->where('coupon_detail.join_coupon_detail_member_id', $memberId)
- ->where('coupon_detail.coupon_detail_gain_datetime', '<=', date('Y-m-d H:i:s'))
- ->where('coupon_detail.coupon_detail_deadline_datetime', '>=', date('Y-m-d H:i:s'));
- if ($settlementNow == 'Y' && $type == 'pay') {
- $couponDetail = $couponDetail->whereIn('coupon_detail.coupon_detail_status', ['ACTIVED']);
- } else {
- $couponDetail = $couponDetail->where('coupon_detail.coupon_detail_status', 'ACTIVED');
- }
- $couponDetail = $couponDetail->orderBy('coupon_detail_id', 'DESC')
- ->first();
- if (!$couponDetail) {
- continue;
- }
- if ($settlementNow == 'Y') {
- $updateData = [
- 'coupon_detail_status' => 'USED',
- 'coupon_detail_used_datetime' => date('Y-m-d H:i:s'),
- ];
- } else {
- $updateData = [
- 'coupon_detail_status' => 'WAITING',
- ];
- }
- // 计算优惠券包含的优惠商品的件数和总价
- $countAndAmount = self::countAndAmount($goods, $couponId);
- // 如果是计件
- if ($couponDetail->coupon_category == 'PIECE' && $countAndAmount['count'] < $couponDetail->coupon_minimum_limit) {
- continue;
- }
- if (in_array($couponDetail->coupon_classify, ['立减券', '满减券'])) {
- if (Redis::sIsMember($cacheKey, $couponId)) {
- continue;
- }
- Redis::sAdd($cacheKey, $couponId);
- if ($couponDetail->coupon_category == 'PIECE' || ($couponDetail->coupon_category == 'NORMAL' && $countAndAmount['amount'] >= $couponDetail->coupon_minimum_limit)) {
- $payAmount = $payAmount - $couponDetail->coupon_value;
- // json记录
- $discountData[$couponId] = [
- 'coupon_id' => $couponId,
- 'coupon_value' => $couponDetail->coupon_value,
- 'coupon_classify' => $couponDetail->coupon_classify,
- 'coupon_detail_id' => [$couponDetail->coupon_detail_id]
- ];
- Redis::set($cacheDiscountKey, json_encode($discountData, JSON_UNESCAPED_UNICODE));
- CouponDetail::where('coupon_detail_id', $couponDetail->coupon_detail_id)->update($updateData);
- }
- } elseif ($couponDetail->coupon_classify == '折扣券') {
- if (Redis::sIsMember($cacheKey, $couponId)) {
- continue;
- }
- Redis::sAdd($cacheKey, $couponId);
- if ($couponDetail->coupon_category == 'PIECE' || $couponDetail->coupon_category == 'PROMOTION' || ($couponDetail->coupon_category == 'NORMAL' && $countAndAmount['amount'] >= $couponDetail->coupon_minimum_limit)) {
- $zhekouAmount = round($countAndAmount['amount'] * (100 - $couponDetail->coupon_value) / 100, 2);
- $payAmount = $payAmount - $zhekouAmount;
- // json记录
- $discountData[$couponId] = [
- 'coupon_id' => $couponId,
- 'coupon_value' => $zhekouAmount,
- 'coupon_classify' => $couponDetail->coupon_classify,
- 'coupon_detail_id' => [$couponDetail->coupon_detail_id]
- ];
- Redis::set($cacheDiscountKey, json_encode($discountData, JSON_UNESCAPED_UNICODE));
- CouponDetail::where('coupon_detail_id', $couponDetail->coupon_detail_id)->update($updateData);
- }
- } elseif (in_array($couponDetail->coupon_classify, ['抵用券', '赠品券'])) {
- if (Redis::sIsMember($cacheKey, $couponId)) {
- continue;
- }
- Redis::sAdd($cacheKey, $couponId);
- CouponDetail::where('coupon_detail_id', $couponDetail->coupon_detail_id)->update($updateData);
- if ($good['nbr'] > 1) {
- $diyongAmount = $good['goods_sales_price'];
- $payAmount = $payAmount - $diyongAmount;
- } elseif (ceil($good['nbr']) == 1) {
- $diyongAmount = round($good['goods_sales_price'] * $good['nbr'], 2);
- $payAmount = $payAmount - $diyongAmount;
- }
- // json记录
- $discountData[$couponId] = [
- 'coupon_id' => $couponId,
- 'coupon_value' => $diyongAmount,
- 'coupon_classify' => $couponDetail->coupon_classify,
- 'coupon_detail_id' => [$couponDetail->coupon_detail_id]
- ];
- Redis::set($cacheDiscountKey, json_encode($discountData, JSON_UNESCAPED_UNICODE));
- } elseif ($couponDetail->coupon_classify == '福利券') {
- if (Redis::sIsMember($cacheKey, $couponId)) {
- continue;
- }
- Redis::sAdd($cacheKey, $couponId);
- CouponDetail::where('coupon_detail_id', $couponDetail->coupon_detail_id)->update($updateData);
- $fuliAmount = 0;
- if (!empty($couponDetail->coupon_value)) {
- $fuliAmount = $couponDetail->coupon_value;
- }
- if ($fuliAmount >= $countAndAmount['amount']) {
- $preferentialAmount = $countAndAmount['amount'];
- } else {
- $preferentialAmount = $fuliAmount;
- }
- $payAmount = $payAmount - $preferentialAmount;
- // json记录
- $discountData[$couponId] = [
- 'coupon_id' => $couponId,
- 'coupon_value' => $preferentialAmount,
- 'coupon_classify' => $couponDetail->coupon_classify,
- 'coupon_detail_id' => [$couponDetail->coupon_detail_id]
- ];
- Redis::set($cacheDiscountKey, json_encode($discountData, JSON_UNESCAPED_UNICODE));
- } elseif (in_array($couponDetail->coupon_classify, ['年卡', '季卡', '月卡'])) {
- if (Redis::sIsMember($cacheKey, $couponId) || Redis::sIsMember($cacheKey, $goodsId)) {
- continue;
- }
- Redis::sAdd($cacheKey, $couponId);
- Redis::sAdd($cacheKey, $goodsId);
- $kaAmount = 0;
- if (!empty($discountData[$couponId]['coupon_value'])) {
- $kaAmount = $discountData[$couponId]['coupon_value'];
- }
- if ($good['nbr'] > 1) {
- $payAmount = $payAmount - $good['goods_sales_price'];
- $kaAmount = $good['goods_sales_price'];
- } else {
- $payAmount = $payAmount - $good['goods_sales_price'] * $good['nbr'];
- $kaAmount = $good['goods_sales_price'] * $good['nbr'];
- }
- // json记录
- $discountData[$couponId] = [
- 'coupon_id' => $couponId,
- 'coupon_value' => $kaAmount,
- 'coupon_classify' => $couponDetail->coupon_classify,
- 'coupon_detail_id' => [$couponDetail->coupon_detail_id]
- ];
- Redis::set($cacheDiscountKey, json_encode($discountData, JSON_UNESCAPED_UNICODE));
- }
- }
- if ($payAmount < 0) {
- $payAmount = 0;
- }
- $amountBalance = [
- 'pay_amount' => round($payAmount, 2),
- 'welfare_balance' => 0,
- 'cut_balance' => 0
- ];
- return $amountBalance;
- } catch (\Exception $e) {
- Redis::del("ORDER:USE:COUPON:" . $memberId);
- Redis::del("ORDER:USE:COUPON:DISCOUNT:" . $memberId);
- dump($e->getTrace());
- }
- }
- /**
- * @Desc 选择优惠券,计算
- * @Author Gorden
- * @Date 2024/8/28 14:18
- *
- * @param $memberId
- * @param $goods
- * @param $good
- * @param $coupon
- * @param $amountBalance
- * @return array|void
- */
- public static function chooseCoupon($settlementNow, $memberId, $goods, $good, $coupon, $amountBalance)
- {
- try {
- $cacheKey = "ORDER:USE:COUPON:" . $memberId;
- $payAmount = $amountBalance['pay_amount'];
- $welfareBalance = $amountBalance['welfare_balance'];
- $cutBalance = $amountBalance['cut_balance'];
- $goodsId = $good['goods_id'];
- $money = $good['goods_sales_price'] * $good['nbr'];
- foreach ($coupon as $couponId) {
- $couponDetail = CouponDetail::leftJoin('coupon_goods', 'coupon_goods.join_goods_coupon_id', '=', 'coupon_detail.join_detail_coupon_id')
- ->leftJoin('coupon', 'coupon.coupon_id', '=', 'coupon_detail.join_detail_coupon_id')
- ->select('coupon_detail.coupon_detail_id', 'coupon_goods.coupon_goods_id', 'coupon_id', 'coupon_classify', 'coupon_value', 'coupon_minimum_limit', 'coupon_category')
- ->where('coupon_goods.join_coupon_goods_id', $goodsId)
- // ->where('coupon_goods.join_coupon_goods_sku_id', $good['sku_id'])
- ->where('join_goods_coupon_id', $couponId)
- ->where('coupon_detail.join_coupon_detail_member_id', $memberId)
- ->where('coupon_detail.coupon_detail_gain_datetime', '<', date('Y-m-d H:i:s'))
- ->where('coupon_detail.coupon_detail_deadline_datetime', '>', date('Y-m-d H:i:s'));
- if ($settlementNow == 'Y') {
- $couponDetail = $couponDetail->whereIn('coupon_detail.coupon_detail_status', ['ACTIVED']);
- } else {
- $couponDetail = $couponDetail->where('coupon_detail.coupon_detail_status', 'ACTIVED');
- }
- $couponDetail = $couponDetail->orderBy('coupon_detail_id', 'DESC')
- ->first();
- if (!$couponDetail) {
- continue;
- }
- // 计算优惠券包含的优惠商品的件数和总价
- $countAndAmount = self::countAndAmount($goods, $couponId);
- // 如果是计件
- if ($couponDetail->coupon_category == 'PIECE' && $countAndAmount['count'] < $couponDetail->coupon_minimum_limit) {
- continue;
- }
- if (in_array($couponDetail->coupon_classify, ['立减券','满减券'])) {
- if (Redis::sIsMember($cacheKey, $couponId)) {
- continue;
- }
- Redis::sAdd($cacheKey, $couponId);
- if ($couponDetail->coupon_category == 'PIECE' || ($couponDetail->coupon_category == 'NORMAL' && $countAndAmount['amount'] >= $couponDetail->coupon_minimum_limit)) {
- $payAmount = $payAmount - $couponDetail->coupon_value;
- }
- }
- // elseif ($couponDetail->coupon_classify == '满减券') {
- // if (Redis::sIsMember($cacheKey, $couponId)) {
- // continue;
- // }
- // Redis::sAdd($cacheKey, $couponId);
- // // 计件
- // if ($couponDetail->coupon_category == 'PIECE' && $countAndAmount['count'] >= $couponDetail->coupon_minimum_limit) {
- // $goodsIds = array_splice($countAndAmount['goodsIds'], 0, $couponDetail->coupon_value);
- // $amount = 0;
- // $goodsNbr = 0;
- // foreach ($goods as $countAndAmountGood) {
- // if (in_array($countAndAmountGood['goods_id'], $goodsIds) && $goodsNbr < $couponDetail->coupon_value) {
- // if ($goodsNbr + $countAndAmountGood['nbr'] <= $couponDetail->coupon_value) {
- // $amount = $amount + round($countAndAmountGood['goods_sales_price'] * $countAndAmountGood['nbr'], 2);
- // $goodsNbr += $countAndAmountGood['nbr'];
- // } elseif ($goodsNbr + $countAndAmountGood['nbr'] > $couponDetail->coupon_value) {
- // $amount = $amount + round($countAndAmountGood['goods_sales_price'] * ($couponDetail->coupon_value - $goodsNbr), 2);
- // $goodsNbr = $couponDetail->coupon_value - $goodsNbr;
- // }
- // }
- // }
- // $payAmount = $payAmount - $amount;
- // }else if ($couponDetail->coupon_category == 'NORMAL' && $countAndAmount['amount'] >= $couponDetail->coupon_minimum_limit) { // 金额
- // $payAmount = $payAmount - $couponDetail->coupon_value;
- // }
- // }
- elseif ($couponDetail->coupon_classify == '折扣券') {
- if (Redis::sIsMember($cacheKey, $couponId)) {
- continue;
- }
- Redis::sAdd($cacheKey, $couponId);
- if ($couponDetail->coupon_category == 'PIECE' || $couponDetail->coupon_category == 'PROMOTION' || ($couponDetail->coupon_category == 'NORMAL' && $countAndAmount['amount'] >= $couponDetail->coupon_minimum_limit)) {
- $zhekouAmount = round($countAndAmount['amount'] * (100 - $couponDetail->coupon_value) / 100, 2);
- $payAmount = $payAmount - $zhekouAmount;
- }
- } elseif (in_array($couponDetail->coupon_classify, ['抵用券', '赠品券'])) {
- if (Redis::sIsMember($cacheKey, $couponId)) {
- continue;
- }
- Redis::sAdd($cacheKey, $couponId);
- if ($good['nbr'] > 1) {
- $diyongAmount = $good['goods_sales_price'];
- $payAmount = $payAmount - $diyongAmount;
- } elseif (ceil($good['nbr']) == 1) {
- $diyongAmount = round($good['goods_sales_price'] * $good['nbr'], 2);
- $payAmount = $payAmount - $diyongAmount;
- }
- } elseif ($couponDetail->coupon_classify == '福利券') {
- if (Redis::sIsMember($cacheKey, $couponId)) {
- continue;
- }
- Redis::sAdd($cacheKey, $couponId);
- $fuliAmount = 0;
- if (!empty($couponDetail->coupon_value)) {
- $fuliAmount = $couponDetail->coupon_value;
- }
- if ($fuliAmount >= $countAndAmount['amount']) {
- $preferentialAmount = $countAndAmount['amount'];
- } else {
- $preferentialAmount = $fuliAmount;
- }
- $payAmount = $payAmount - $preferentialAmount;
- } elseif (in_array($couponDetail->coupon_classify, ['年卡', '季卡', '月卡'])) {
- if (Redis::sIsMember($cacheKey, $couponId) || Redis::sIsMember($cacheKey, $goodsId)) {
- continue;
- }
- Redis::sAdd($cacheKey, $couponId);
- Redis::sAdd($cacheKey, $goodsId);
- if ($good['nbr'] > 1) {
- $payAmount = $payAmount - $good['goods_sales_price'];
- } else {
- $payAmount = $payAmount - $good['goods_sales_price'] * $good['nbr'];
- }
- }
- }
- if ($payAmount < 0) {
- $payAmount = 0;
- }
- $amountBalance = [
- 'pay_amount' => round($payAmount, 2),
- 'welfare_balance' => $welfareBalance,
- 'cut_balance' => $cutBalance
- ];
- return $amountBalance;
- } catch (\Exception $e) {
- Redis::del("ORDER:USE:COUPON:" . $memberId);
- Redis::del("ORDER:USE:COUPON:DISCOUNT:" . $memberId);
- dump($e->getTrace());
- }
- }
- public static function countAndAmount($goods, $couponId)
- {
- try {
- $goodsIds = array_column($goods, 'goods_id');
- $couponGoods = CouponGoods::whereIn('join_coupon_goods_id', $goodsIds)
- ->where('join_goods_coupon_id', $couponId)
- // ->select('join_coupon_goods_id', 'join_coupon_goods_sku_id')
- ->get()
- ->toArray();
- $count = 0;
- $amount = 0;
- $goodsIds = [];
- foreach ($couponGoods as $couponGood) {
- foreach ($goods as $good) {
- // if ($good['goods_id'] == $couponGood['join_coupon_goods_id'] && $good['sku_id'] == $couponGood['join_coupon_goods_sku_id']) {
- if ($good['goods_id'] == $couponGood['join_coupon_goods_id']) {
- $count += $good['nbr'];
- $amount += $good['goods_sales_price'] * $good['nbr'];
- $goodsIds[] = $good['goods_id'];
- }
- }
- }
- return compact('count', 'amount', 'goodsIds');
- } catch (\Exception $e) {
- dump($e->getTrace());
- }
- }
- /**
- * @Desc
- * @Author Gorden
- * @Date 2024/9/11 11:11
- *
- * @param MemberBenefit $benefit
- * @return false[]|true[]
- */
- public static function checkPackageBenefit(MemberBenefit $benefit)
- {
- $result = ['sheet' => true, 'order' => true];
- // 除此权益外,套包的其他权益是否用完了 where('join_benefit_package_id', $benefit->join_benefit_package_id)
- $benefits = MemberBenefit::where('join_benefit_order_id', $benefit->join_benefit_order_id)
- ->where('member_benefit_id', '<>', $benefit->member_benefit_id)
- ->get()
- ->toArray();
- foreach ($benefits as $benefitItem) {
- if ($benefitItem['join_benefit_package_id'] == $benefit->join_benefit_package_id) {
- if ($benefitItem['member_benefit_limit_count'] > $benefitItem['member_benefit_used_count']) {
- return ['sheet' => false, 'order' => false];
- }
- }
- }
- foreach ($benefits as $benefitItem) {
- if ($benefitItem['member_benefit_limit_count'] > $benefitItem['member_benefit_used_count']) {
- $result['order'] = false;
- return $result;
- }
- }
- return $result;
- }
- /**
- * @Desc 拆单提成
- * @Author Gorden
- * @Date 2024/9/29 16:27
- *
- * @return void
- */
- public static function splitOrderCommission($params)
- {
- $orders = Order::where('order_groupby', $params['orderGroupId'])->get()->toArray();
- if (!empty($orders)) {
- foreach ($orders as $orderItem) {
- $params['member_id'] = $orderItem['join_order_member_id'];
- $params['orderId'] = $orderItem['order_id'];
- Event::dispatch('commission.order', $params);
- }
- }
- }
- public static function splitOrderStatisticsInOut($params)
- {
- $orders = Order::where('order_groupby', $params['orderGroupId'])->get()->toArray();
- if (!empty($orders)) {
- foreach ($orders as $orderItem) {
- $params['member_id'] = $orderItem['join_order_member_id'];
- $params['orderId'] = $orderItem['order_id'];
- $params['inout_category'] = '标准订单';
- Event::dispatch('statistics.inout.in', $params);
- }
- }
- }
- /**
- * 检查产品限额
- */
- public static function checkGoodsLimit($goods,$memberId)
- {
- foreach($goods as $good){
- $goodsLimit = 'no';
- $goodsModel = Goods::where('goods_id',$good['goods_id'])->select('goods_attribute_json')->first();
- if (!empty($goodsModel) && !empty($goodsModel->goods_attribute_json)){
- $goodsAttributeJson = json_decode($goodsModel->goods_attribute_json,true);
- if (!empty($goodsAttributeJson['max-limit'])){
- $goodsLimit = $goodsAttributeJson['max-limit'];
- if ($goodsLimit != 0 && $goodsLimit != '' && $good['nbr'] > $goodsLimit){
- return false;
- }
- }
- }
-
- $sheetNbr = 0;
- if ($goodsLimit != 'no'){
- $sheetNbr = OrderSheet::where('join_sheet_member_id',$memberId)
- ->where('join_sheet_goods_id',$good['goods_id'])
- ->where('order_sheet_status','<>','CANCEL')
- ->sum('order_sheet_num');
- if ($goodsLimit != 0 && $goodsLimit != '' && $good['nbr'] + $sheetNbr > $goodsLimit){
- return false;
- }
- }
- }
- return true;
- }
- public static $couponClassify = [
- 'wipe' => '抹零',
- 'custom' => '自定义优惠金额'
- ];
- public static $payWay = [
- 'WXPAY' => '微信支付',
- 'ALIPAY' => '支付宝',
- 'CASH' => '账户余额',
- 'CARD' => '储值卡',
- 'WELFARE' => '福利账户',
- 'MONEY' => '现金',
- 'OFFLINE' => '线下支付',
- 'OFFLINE_WXPAY' => '微信支付(线下)',
- 'OFFLINE_ALIPAY' => '支付宝(线下)',
- 'QRCODE' => '付款码',
- 'NONE' => '付零',
- 'VIP' => 'VIP账户'
- ];
- public static $orderClassify = [
- 'GOODS' => '产品订单',
- 'CHNMED' => '服务订单',
- 'CHNNCD' => '服务订单',
- 'SERVICE' => '服务订单',
- 'DEVICE' => '设备订单',
- 'SPECIAL' => '专题业务订单',
- 'PACKAGE' => '套包订单',
- 'RECHARGE' => '充值订单',
- 'DESHES' => '餐饮订单',
- 'VIP' => '康养城订单',
- 'PARTNER' => '合伙人订单',
- 'REFERRER' => '康养推荐官订单',
- 'COMBINE' => '新客专享订单'
- ];
- /**
- * @Desc 更新订单 sheet
- * @Author Gorden
- * @Date 2024/10/21 11:18
- *
- * @param Order $order
- * @param $status
- * @return void
- */
- public static function updateSheet(Order $order, $status)
- {
- $sheets = OrderSheet::where('join_sheet_order_id', $order->order_id)->get()->toArray();
- foreach ($sheets as $sheet) {
- $sheetPricePay = round(($order->order_amount_pay / $order->order_amount_total) * $sheet['order_sheet_price'], true);
- OrderSheet::where('order_sheet_id', $sheet['order_sheet_id'])->update([
- 'order_sheet_status' => $status,
- 'order_sheet_price_pay' => $sheetPricePay,
- 'order_sheet_pay' => $sheetPricePay * $sheet['order_sheet_num']
- ]);
- }
- }
- }
|