123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999 |
- <?php
- namespace app\admin\controller\order;
- use app\admin\service\member\MemberService;
- use app\admin\validate\order\ReturnValidate;
- use app\controller\Curd;
- use app\model\CouponDetail;
- use app\model\GoodsComponent;
- use app\model\Member;
- use app\model\MemberAccount;
- use app\model\Order;
- use app\model\OrderExpress;
- use app\model\OrderReturn;
- use app\model\OrderSheet;
- use app\model\PayDetail;
- use app\model\SysUser;
- use Payment\Common\PayException;
- use support\Db;
- use support\exception\BusinessException;
- use support\Log;
- use support\Request;
- use support\Response;
- use Tinywan\Jwt\JwtToken;
- use Webman\Event\Event;
- use Yansongda\Pay\Pay;
- class RefundController extends Curd
- {
- public function __construct()
- {
- $this->model = new OrderReturn();
- $this->validate = true;
- $this->validateClass = new ReturnValidate();
- }
- public function select(Request $request): Response
- {
- [$where, $format, $limit, $field, $order] = $this->selectInput($request);
- $order = $request->get('order', 'desc');
- $type = $request->get('type', '');
- $field = $field ?? 'order_return_addtimes';
- $where['order_return_category'] = ['in', ['退款', '会员退款']];
- if (!empty($where['order_return_addtimes'])) {
- $where['order_return_addtimes'][0] = strtotime($where['order_return_addtimes'][0]);
- $where['order_return_addtimes'][1] = strtotime($where['order_return_addtimes'][1]);
- }
- if ($type == 'today') {
- $where['order_return_addtimes'] = [
- strtotime(date('Y-m-d') . ' 00:00:00'),
- strtotime(date('Y-m-d') . ' 23:59:59')
- ];
- }
- $query = $this->doSelect($where, $field, $order);
- return $this->doFormat($query, $format, $limit);
- }
- protected function doSelect(array $where, string $field = null, string $order = 'desc')
- {
- $model = $this->model->with([
- 'member' => function ($query) {
- $query->select('member_id', 'member_mobile');
- },
- 'cert' => function ($query) {
- $query->select('join_cert_member_id', 'member_cert_name');
- },
- 'order' => function ($query) {
- $query->select('order_id', 'order_name');
- }
- ]);
- foreach ($where as $column => $value) {
- if (is_array($value)) {
- if ($value[0] === 'like' || $value[0] === 'not like') {
- $model = $model->where($column, $value[0], "%$value[1]%");
- } elseif (in_array($value[0], ['>', '=', '<', '<>'])) {
- $model = $model->where($column, $value[0], $value[1]);
- } elseif ($value[0] == 'in' && !empty($value[1])) {
- $valArr = $value[1];
- if (is_string($value[1])) {
- $valArr = explode(",", trim($value[1]));
- }
- $model = $model->whereIn($column, $valArr);
- } elseif ($value[0] == 'not in' && !empty($value[1])) {
- $valArr = $value[1];
- if (is_string($value[1])) {
- $valArr = explode(",", trim($value[1]));
- }
- $model = $model->whereNotIn($column, $valArr);
- } elseif ($value[0] == 'null') {
- $model = $model->whereNull($column);
- } elseif ($value[0] == 'not null') {
- $model = $model->whereNotNull($column);
- } elseif ($value[0] !== '' || $value[1] !== '') {
- $model = $model->whereBetween($column, $value);
- }
- } else {
- $model = $model->where($column, $value);
- }
- }
- if ($field) {
- $model = $model->orderBy($field, $order);
- }
- return $model;
- }
- public function afterQuery($items)
- {
- foreach ($items as &$item) {
- if (!empty($item['order'])) {
- $orderSheet = OrderSheet::with([
- 'goods' => function ($query) {
- $query->select('goods_id', 'goods_name');
- }
- ])->select('join_sheet_order_id', 'join_sheet_goods_id')
- ->where('join_sheet_order_id', $item['order']->order_id)
- ->get()
- ->toArray();
- $goodsName = !empty($orderSheet) ? $orderSheet[0]['goods']['goods_name'] : '';
- if (count($orderSheet) > 1) {
- $goodsName .= ' 等';
- }
- $item['goods_name'] = $goodsName;
- }
- if (!empty($item['order_return_apply_json']) && is_json($item['order_return_apply_json'])) {
- // $json = json_decode($item['order_return_apply_json'], true);
- // $item['order_return_apply_json'] = $json['apply'] ?? '';
- }
- if (!empty($item['order_return_recharge_json']) && is_json($item['order_return_recharge_json'])) {
- $json = json_decode($item['order_return_recharge_json'], true);
- $item['order_return_recharge_json'] = $json['change'] ?? '';
- }
- if (!empty($item['order_return_refund_json']) && is_json($item['order_return_refund_json'])) {
- $returnRefundJson = json_decode($item['order_return_refund_json'], true);
- if (!empty($returnRefundJson['user_id'])) {
- $item['userName'] = SysUser::where('user_id', $returnRefundJson['user_id'])->value('user_name');
- }
- }
- }
- return $items;
- }
- /**
- * @Desc 退款管理顶部统计
- * @Author Gorden
- * @Date 2024/10/31 11:37
- *
- * @param Request $request
- * @return Response
- */
- public function statistics(Request $request)
- {
- $status = $request->get('order_return_status');
- $memberId = $request->get('join_return_member_id');
- $orderId = $request->get('orderId');
- $orderReturnAddtimes = $request->get('order_return_addtimes');
- if (!empty($orderReturnAddtimes)) {
- $orderReturnAddtimes[0] = strtotime($orderReturnAddtimes[0]);
- $orderReturnAddtimes[1] = strtotime($orderReturnAddtimes[1]);
- }
- $returnModel = OrderReturn::when(!empty($status), function ($query) use ($status) {
- $query->where('order_return_status', $status);
- })->when(!empty($memberId), function ($query) use ($memberId) {
- $query->where('join_return_member_id', $memberId);
- })->when(!empty($orderId), function ($query) use ($orderId) {
- $query->where('join_return_order_id', 'like', '%' . $orderId . '%');
- })->when(!empty($orderReturnAddtimes), function ($query) use ($orderReturnAddtimes) {
- $query->whereBetween('order_return_addtimes', $orderReturnAddtimes);
- });
- $totalModel = clone $returnModel;
- $total = $totalModel->selectRaw("SUM(JSON_UNQUOTE(JSON_EXTRACT(order_return_apply_json,'$.amount'))) as amount,count(orders_return_id) as total")
- ->first()
- ->toArray();
- $pendingTotalModel = clone $returnModel;
- $pendingTotal = $pendingTotalModel->where('order_return_status', 'PENDING')
- ->selectRaw("SUM(JSON_UNQUOTE(JSON_EXTRACT(order_return_apply_json,'$.amount'))) as amount,count(orders_return_id) as total")
- ->first()
- ->toArray();
- $doingTotalModel = clone $returnModel;
- $doingTotal = $doingTotalModel->where('order_return_status', 'DOING')
- ->selectRaw("SUM(JSON_UNQUOTE(JSON_EXTRACT(order_return_apply_json,'$.amount'))) as amount,count(orders_return_id) as total")
- ->first()
- ->toArray();
- $disagreeTotalModel = clone $returnModel;
- $disagreeTotal = $disagreeTotalModel->where('order_return_status', 'DISAGREE')
- ->selectRaw("SUM(JSON_UNQUOTE(JSON_EXTRACT(order_return_apply_json,'$.amount'))) as amount,count(orders_return_id) as total")
- ->first()
- ->toArray();
- $doneTotalModel = clone $returnModel;
- $doneTotal = $doneTotalModel->where('order_return_status', 'DONE')
- ->selectRaw("SUM(JSON_UNQUOTE(JSON_EXTRACT(order_return_apply_json,'$.amount'))) as amount,count(orders_return_id) as total")
- ->first()
- ->toArray();
- return json_success('success', [
- 'total' => $total,
- 'pendingTotal' => $pendingTotal,
- 'doingTotal' => $doingTotal,
- 'disagreeTotal' => $disagreeTotal,
- 'doneTotal' => $doneTotal
- ]);
- }
- protected function updateInput(Request $request): array
- {
- $primary_key = $this->model->getKeyName();
- $id = $request->post($primary_key);
- $data = $this->inputFilter($request->post());
- $model = $this->model->find($id);
- if (!$model) {
- throw new BusinessException('记录不存在', 2);
- }
- if (empty($model->order_return_accept_datetimes) && $model->order_return_status == 'PENDING' && $data['order_return_status'] == 'DOING') {
- $data['order_return_accept_datetimes'] = date('Y-m-d H:i:s');
- }
- if (!empty($data['order_return_apply_json'])) {
- $data['order_return_apply_json'] = json_encode(['apply' => $data['order_return_apply_json']]);
- }
- if (!empty($data['order_return_recharge_json'])) {
- $data['order_return_recharge_json'] = json_encode(['change' => $data['order_return_recharge_json']]);
- }
- unset($data[$primary_key]);
- return [$id, $data];
- }
- /**
- * @Desc 订单商品详情
- * @Author Gorden
- * @Date 2024/3/29 8:50
- *
- * @param Request $request
- * @return Response
- */
- public function sheet(Request $request)
- {
- $orderId = $request->get('order_id');
- $orderSheet = OrderSheet::with([
- 'member' => function ($query) {
- $query->select('member_id', 'member_mobile', 'join_member_role_id', 'member_is_owner', 'member_is_vip', 'member_is_partner', 'member_is_referrer');
- },
- 'goods' => function ($query) {
- $query->select('goods_id', 'goods_name', 'goods_cover', 'goods_market_price', 'goods_sales_price', 'goods_classify');
- },
- 'sku' => function ($query) {
- $query->select('goods_sku_id', 'join_sku_goods_id', 'goods_sku_specs_json', 'goods_sku_sales_price');
- },
- 'memberInfo',
- 'cert',
- 'refund'
- ])->where('join_sheet_order_id', $orderId)
- ->get()
- ->toArray();
- $member = [];
- $cert = [];
- $memberInfo = [];
- $sheets = [];
- foreach ($orderSheet as &$item) {
- if (isset($item['member']) && empty($member)) {
- $member = $item['member'];
- $member['level'] = MemberService::getRoleName($member['join_member_role_id'] ?? '');
- }
- if (isset($item['cert']) && empty($cert)) {
- $cert = $item['cert'];
- }
- if (isset($item['member_info']) && empty($memberInfo)) {
- $memberInfo = $item['member_info'];
- $memberInfo['member_info_nickname'] = $memberInfo['member_info_nickname'] ?? MemberService::getMemberNickname($member['member_mobile'] ?? '');
- $memberInfo['member_info_headimg'] = MemberService::getAvatarUrl($memberInfo['member_info_headimg'] ?? '');
- }
- $item['goods']['goods_cover'] = getenv('STORAGE_DOMAIN') . $item['goods']['goods_cover'];
- if (!empty($item['goods']) && $item['goods']['goods_classify'] == 'PACKAGE') {
- $components = GoodsComponent::with('goods')
- ->where('join_component_master_goods_id', $item['goods']['goods_id'])
- ->select('join_component_master_goods_id', 'join_component_goods_id', 'goods_component_price',
- 'goods_component_price')
- ->get()
- ->toArray();
- $goodsArr = [];
- foreach ($components as $component) {
- $configJson = !empty($component['goods_component_config_json']) ? json_decode($component['goods_component_config_json'], true) : [];
- if (!empty($component['goods'])) {
- $goodsArr[] = [
- 'goods_name' => $component['goods']['goods_name'],
- 'goods_cover' => getenv('STORAGE_DOMAIN') . $component['goods']['goods_cover'],
- 'nbr' => $configJson['nbr'] ?? 0,
- ];
- }
- }
- $item['goods']['components'] = $goodsArr;
- }
- if (!empty($item['sku'])) {
- if (!empty($item['sku']['goods_sku_specs_json'])) {
- $specsJson = json_decode($item['sku']['goods_sku_specs_json'], true);
- $skuName = '';
- foreach ($specsJson as $specsKey => $skuSpecs) {
- if (is_array($skuSpecs)) {
- $skuName = $skuName . ' ' . implode(' ', $skuSpecs) . ';';
- } else {
- $skuName = $skuName . ' ' . $skuSpecs . ';';
- }
- }
- $item['sku']['goods_sku_title'] = rtrim($skuName, ';');
- }
- }
- if (!empty($item['refund'])) {
- if (!empty($item['refund']['order_return_apply_json']) && is_json($item['refund']['order_return_apply_json'])) {
- $json = json_decode($item['refund']['order_return_apply_json'], true);
- $item['refund']['order_return_apply_json'] = $json['reason'] ?? '';
- }
- if (!empty($item['refund']['order_return_recharge_json']) && is_json($item['refund']['order_return_recharge_json'])) {
- $json = json_decode($item['refund']['order_return_recharge_json'], true);
- $item['refund']['order_return_recharge_json'] = $json['change'] ?? '';
- }
- }
- }
- $order = Order::where('order_id', $orderId)->first();
- $return = OrderReturn::where('join_return_order_id', $orderId)->first();
- if (!empty($return->order_return_refund_json)) {
- $returnRefundJson = json_decode($return->order_return_refund_json, true);
- if (!empty($returnRefundJson['user_id'])) {
- $return->userName = SysUser::where('user_id', $returnRefundJson['user_id'])->value('user_name');
- }
- }
- if (!empty($return->order_return_apply_json)) {
- $returnApplyJson = json_decode($return->order_return_apply_json, true);
- if (!empty($returnApplyJson['order_id'])) {
- $sheets = OrderSheet::with([
- 'goods' => function ($query) {
- $query->select('goods_id', 'goods_name', 'goods_cover', 'goods_market_price', 'goods_sales_price', 'goods_classify');
- },
- 'sku' => function ($query) {
- $query->select('goods_sku_id', 'join_sku_goods_id', 'goods_sku_specs_json', 'goods_sku_sales_price');
- },
- ])->whereIn('join_sheet_order_id', $returnApplyJson['order_id'])
- ->select('order_sheet_id', 'join_sheet_goods_id', 'join_sheet_goods_sku_id', 'order_sheet_num', 'order_sheet_price', 'order_sheet_amount')
- ->get()
- ->toArray();
- foreach ($sheets as $key => $sheetsItem) {
- if (empty($sheetsItem['goods'])) {
- unset($sheets[$key]);
- continue;
- }
- $sheets[$key]['goods']['goods_cover'] = getenv('STORAGE_DOMAIN') . $sheetsItem['goods']['goods_cover'];
- if (!empty($sheetsItem['sku'])) {
- if (!empty($item['sku']['goods_sku_specs_json'])) {
- $specsJson = json_decode($item['sku']['goods_sku_specs_json'], true);
- $skuName = '';
- foreach ($specsJson as $specsKey => $skuSpecs) {
- if (is_array($skuSpecs)) {
- $skuName = $skuName . ' ' . implode(' ', $skuSpecs) . ';';
- } else {
- $skuName = $skuName . ' ' . $skuSpecs . ';';
- }
- }
- $sheets[$key]['sku']['goods_sku_title'] = rtrim($skuName, ';');
- }
- }
- }
- $sheets = array_values($sheets);
- }
- }
- $express = OrderExpress::where('join_express_order_id', $orderId)->first();
- $payDetails = PayDetail::where('join_pay_order_id', $order->order_groupby)
- ->whereJsonContains('join_pay_object_json->order_id', $orderId)
- ->where('pay_status', 'SUCCESS')
- ->where('pay_category', '<>', 'REFUND')
- ->get()
- ->toArray();
- if (count($payDetails) > 1) {
- $order->pay_category = 'CONSTITUTE';
- }
- $payDetail = !empty($payDetails) && count($payDetails) > 0 ? $payDetails[0] : [];
- if (!empty($payDetail) && !empty($payDetail['pay_prepayid'])) {
- $categoryArray = explode('-', $payDetail['pay_prepayid']);
- if (isset($categoryArray[1])) {
- $payDetail['pay_category'] = $categoryArray[1];
- } else if (in_array($categoryArray[0], ['WXPAY', 'ALIPAY', 'OFFLINE', 'OFFLINE_ALIPAY', 'OFFLINE_WXPAY', 'MONEY'])) {
- $payDetail['pay_category'] = $categoryArray[0];
- }
- }
- $data = [
- 'member' => $member,
- 'cert' => $cert,
- 'member_info' => $memberInfo,
- 'order' => $order,
- 'refund' => $return,
- 'sheet' => $orderSheet,
- 'sheets' => $sheets,
- 'express' => $express,
- 'payDetail' => json_decode(json_encode($payDetail)),
- 'payDetails' => json_decode(json_encode($payDetails))
- ];
- return json_success('', $data);
- }
- /**
- * @Desc 会员退款详情
- * @Author Gorden
- * @Date 2024/10/25 9:21
- *
- * @param Request $request
- * @return Response
- */
- public function rechargeSheet(Request $request)
- {
- $returnId = $request->get('return_id');
- if (!$returnId) {
- return json_fail("参数异常");
- }
- $return = OrderReturn::with([
- 'member' => function ($query) {
- $query->select('member_id', 'member_mobile', 'join_member_role_id', 'member_is_owner', 'member_is_vip', 'member_is_partner', 'member_is_referrer');
- },
- 'info' => function ($query) {
- $query->select('join_info_member_id', 'member_info_nickname', 'member_info_headimg');
- },
- 'cert' => function ($query) {
- $query->select('join_cert_member_id', 'member_cert_name');
- },
- ])->where('orders_return_id', $returnId)
- ->first();
- if (!$return) {
- return json_fail('数据异常');
- }
- $return = $return->toArray();
- $return['role_name'] = MemberService::getRoleName(!empty($return['member']) ? $return['member']['join_member_role_id'] : '');
- $return['info']['member_info_nickname'] = MemberService::getNickname(!empty($return['info']) ? $return['info']['member_info_nickname'] : '', !empty($return['member']) ? $return['member']['member_mobile'] : '');
- $return['info']['member_info_headimg'] = MemberService::getAvatarUrl(!empty($return['info']) ? $return['info']['member_info_headimg'] : '');
- if (!empty($return['order_return_apply_json']) && is_json($return['order_return_apply_json'])) {
- $json = json_decode($return['order_return_apply_json'], true);
- $return['reason'] = $json['reason'] ?? '';
- $return['order_return_apply_json'] = $json;
- }
- if (!empty($return['order_return_recharge_json']) && is_json($return['order_return_recharge_json'])) {
- $json = json_decode($return['order_return_recharge_json'], true);
- $return['change'] = $json['change'] ?? '';
- }
- if (!empty($return['join_order_return_user_id'])) {
- $return['disposeUserName'] = SysUser::where('user_id', $return['join_order_return_user_id'])->value('user_name');
- }
- if (!empty($return['order_return_refund_json'])) {
- $returnRefundJson = json_decode($return['order_return_refund_json'], true);
- if (!empty($returnRefundJson['user_id'])) {
- $return['userName'] = SysUser::where('user_id', $returnRefundJson['user_id'])->value('user_name');
- }
- }
- $data = [
- 'refund' => $return,
- ];
- return json_success('', $data);
- }
- public function customRefund(Request $request)
- {
- $orderId = $request->post('order_id', '');
- $amount = $request->post('refund_amount', 0);
- $password = $request->post('refund_password', '');
- $remark = $request->post('refund_remark', '');
- if (!$orderId || !$amount || !$password) {
- return json_fail('参数异常');
- }
- if ($password != '123456') {
- return json_fail('支付密码错误');
- }
- $order = Order::where('order_id', $orderId)->where('order_status_payment', 'SUCCESS')->first();
- if (!$order) {
- return json_fail("订单异常");
- }
- if ($amount > $order->order_amount_pay) {
- return json_fail("退款金额不能超过支付金额");
- }
- $payDetail = PayDetail::where('join_pay_order_id', $order->order_groupby)
- ->whereJsonContains('join_pay_object_json->order_id', $orderId)
- ->where('pay_status', 'SUCCESS')
- ->where('pay_prepayid','<>','')
- ->whereIn('pay_category', ['GOODS', 'SERVICE', 'CHNMED', 'CHNNCD', 'MEALS', 'DISHES', 'VIP', 'PACKAGE'])
- ->get()
- ->toArray();
- if (empty($payDetail)) {
- return json_fail("支付状态异常");
- }
- $refundPayIds = array_column($payDetail, 'pay_id');
- $response = [];
- Db::beginTransaction();
- try {
- // 全额退款,检查优惠券,恢复可使用
- if (sprintf("%.2f", $amount) == sprintf("%.2f", $order->order_amount_pay)) {
- if (!empty($order->order_discount_json)) {
- $discountJson = json_decode($order->order_discount_json, true);
- foreach ($discountJson as $item) {
- if (empty($item['coupon_id'])) {
- continue;
- }
- // 是否有其他订单一起使用优惠券
- if (!Order::where('order_groupby', $order->order_groupby)->where('order_id', '<>', $order->order_id)->where('order_is_complete', '<>', 'R')->exists()) {
- foreach ($item['coupon_detail_id'] as $detailId) {
- CouponDetail::where('coupon_detail_id', $detailId)->update([
- 'coupon_detail_status' => 'ACTIVED',
- 'coupon_detail_used_datetime' => ''
- ]);
- }
- }
- }
- }
- }
- // 主订单,退款作为优惠入库
- $this->updateMainOrderByRefund($order, $amount, $remark);
- // return 表记录
- $return = OrderReturn::where('join_return_order_id', $orderId)->first();
- if (empty($return)) {
- $returnId = $this->createReturnRecord($order, $amount, $remark);
- } else {
- $returnId = $return->orders_return_id;
- //['amount' => $amount, 'user_id' => JwtToken::getCurrentId(), 'datetime' => date('Y-m-d H:i:s'), 'remark' => $remark ?? '']
- OrderReturn::where('join_return_order_id', $orderId)->update([
- 'order_return_status' => 'DONE',
- 'order_return_refund_json' => json_encode([
- 'amount' => $amount,
- 'user_id' => JwtToken::getCurrentId(),
- 'datetime' => date('Y-m-d H:i:s'),
- 'remark' => $remark ?? ''
- ])
- ]);
- }
- // 组合支付,退到余额账户
- $prepayid = '';
- if (count($payDetail) > 1) {
- $prepayid = $order->join_order_member_id . '-CASH';
- $this->refundToCash($order->join_order_member_id, $amount);
- $response = ['order_id' => $order->order_id, 'member_id' => $order->join_order_member_id];
- } else if (count($payDetail) == 1) {
- $payDetail0 = $payDetail[0];
- $payWay = explode('-', $payDetail0['pay_prepayid']);
- if ($payWay[0] == 'WXPAY') {
- $prepayid = 'WXPAY';
- $response = $this->refundToWx($payDetail0, $returnId, $amount);
- } elseif ($payWay[0] == 'ALIPAY') {
- $prepayid = 'ALIPAY';
- $payDetail0['order_id'] = $order->order_id;
- $response = $this->refundToAlipay($payDetail0, $amount);
- } elseif ($payWay[0] == 'MONEY') {
- $prepayid = 'MONEY';
- // $response = $this->refundToCash($order->join_order_member_id, $amount);
- } elseif (isset($payWay[1]) && $payWay[1] == 'CASH') {
- $prepayid = $order->join_order_member_id . '-CASH';
- $this->refundToCash($order->join_order_member_id, $amount);
- $response = ['order_id' => $order->order_id, 'member_id' => $order->join_order_member_id];
- } elseif (isset($payWay[1]) && $payWay[1] == 'WELFARE') {
- $prepayid = $order->join_order_member_id . '-WELFARE';
- $this->refundToWelfare($order->join_order_member_id, $amount);
- $response = ['order_id' => $order->order_id, 'member_id' => $order->join_order_member_id];
- } elseif (isset($payWay[1]) && $payWay[1] == 'VIP') {
- $prepayid = $order->join_order_member_id . '-VIP';
- $this->refundToVIP($order->join_order_member_id, $amount);
- $response = ['order_id' => $order->order_id, 'member_id' => $order->join_order_member_id];
- } elseif (isset($payWay['1']) && $payWay[1] == 'CARD') {
- $prepayid = $order->join_order_member_id . '-CARD';
- $this->refundToCard($order->join_order_member_id, $amount);
- $response = ['order_id' => $order->order_id, 'member_id' => $order->join_order_member_id];
- } elseif ($payWay[0] == 'OFFLINE') {
- $prepayid = 'OFFLINE';
- $response = [];
- } elseif ($payWay[0] == 'OFFLINE_ALIPAY') {
- $prepayid = 'OFFLINE_ALIPAY';
- $response = [];
- } elseif ($payWay[0] == 'OFFLINE_WXPAY') {
- $prepayid = 'OFFLINE_WXPAY';
- $response = [];
- }
- }
- // payDetail 表记录
- $this->createReturnPayDetail($order, $refundPayIds, $prepayid, $amount, $response);
- Db::commit();
- // 退款入收支
- $params['orderId'] = $orderId;
- $params['type'] = 'refund';
- Event::dispatch('statistics.inout.out', $params);
- return json_success('success');
- } catch (BusinessException $e) {
- Db::rollBack();
- Log::info("退款失败", ['msg' => $e->getMessage()]);
- return json_fail($e->getMessage());
- } catch (\Exception $e) {
- Db::rollBack();
- Log::info("退款失败", ['msg' => $e->getMessage()]);
- return json_fail("退款失败");
- }
- }
- /**
- * @Desc 退款到余额
- * @Author Gorden
- * @Date 2024/8/20 11:54
- *
- * @param $memberId
- * @param $amount
- * @return void
- * @throws BusinessException
- */
- private function refundToCash($memberId, $amount)
- {
- $account = MemberAccount::where('join_account_member_id', $memberId)->where('member_account_classify', 'CASH')->first();
- if (!$account) {
- throw new BusinessException("余额账户异常");
- }
- $account->member_account_surplus = $account->member_account_surplus + $amount;
- $account->member_account_expend = $account->member_account_expend - $amount;
- $account->member_account_update_user_id = JwtToken::getCurrentId();
- $account->member_account_updatetimes = time();
- $account->save();
- }
- /**
- * @Desc 退款到福利账户
- * @Author Gorden
- * @Date 2024/9/20 17:09
- *
- * @param $memberId
- * @param $amount
- * @return void
- * @throws BusinessException
- */
- private function refundToWelfare($memberId, $amount)
- {
- $account = MemberAccount::where('join_account_member_id', $memberId)->where('member_account_classify', 'WELFARE')->first();
- if (!$account) {
- throw new BusinessException("余额账户异常");
- }
- $account->member_account_surplus = $account->member_account_surplus + $amount;
- $account->member_account_expend = $account->member_account_expend - $amount;
- $account->member_account_update_user_id = JwtToken::getCurrentId();
- $account->member_account_updatetimes = time();
- $account->save();
- }
- /**
- * @Desc 退款到VIP账户
- * @Author Gorden
- * @Date 2024/9/20 17:12
- *
- * @param $memberId
- * @param $amount
- * @return void
- * @throws BusinessException
- */
- private function refundToVIP($memberId, $amount)
- {
- $account = MemberAccount::where('join_account_member_id', $memberId)->where('member_account_classify', 'VIP')->first();
- if (!$account) {
- throw new BusinessException("余额账户异常");
- }
- $account->member_account_surplus = $account->member_account_surplus + $amount;
- $account->member_account_expend = $account->member_account_expend - $amount;
- $account->member_account_update_user_id = JwtToken::getCurrentId();
- $account->member_account_updatetimes = time();
- $account->save();
- }
- /**
- * @Desc 退款到储蓄卡
- * @Author Gorden
- * @Date 2024/8/20 14:47
- *
- * @param $memberId
- * @param $amount
- * @return void
- * @throws BusinessException
- */
- private function refundToCard($cardNbr, $amount)
- {
- $account = MemberAccount::where('member_account_nbr', $cardNbr)->where('member_account_classify', 'CARD')->first();
- if (!$account) {
- throw new BusinessException("储值卡账户异常");
- }
- $account->member_account_surplus = $account->member_account_surplus + $amount;
- $account->member_account_expend = $account->member_account_expend - $amount;
- $account->member_account_update_user_id = JwtToken::getCurrentId();
- $account->member_account_updatetimes = time();
- $account->save();
- }
- /**
- * @Desc
- * @Author Gorden
- * @Date 2024/8/20 14:17
- *
- * @param $params
- * @param $returnId
- * @param $amount
- * @return mixed
- * @throws BusinessException
- * @throws \Yansongda\Pay\Exceptions\GatewayException
- * @throws \Yansongda\Pay\Exceptions\InvalidArgumentException
- * @throws \Yansongda\Pay\Exceptions\InvalidSignException
- */
- private function refundToWx($params, $returnId, $amount)
- {
- try {
- $data = [
- 'type' => 'app',
- 'out_trade_no' => $params['join_pay_order_id'],
- 'out_refund_no' => $returnId,
- 'total_fee' => $params['pay_amount'] * 100,
- 'refund_fee' => $amount * 100,
- 'refund_desc' => '退款',
- ];
- $res = Pay::wechat(config('payment.wxpay'))->refund($data);
- $resArray = json_decode($res, true);
- if ($resArray['result_code'] != 'SUCCESS' || $resArray['return_code'] != 'SUCCESS') {
- Log::channel('pay')->error('WXPAY_REFUND_FAIL', $resArray);
- throw new BusinessException("退款失败");
- }
- Log::info("退款响应", $resArray);
- return $resArray;
- } catch (\Exception $e) {
- Log::error("微信退款失败", ['msg' => $e->getMessage()]);
- throw new BusinessException("退款失败");
- }
- }
- /**
- * @Desc 支付宝退款
- * @Author Gorden
- * @Date 2024/8/20 14:40
- *
- * @param $params
- * @param $amount
- * @return mixed
- * @throws BusinessException
- */
- private function refundToAlipay($params, $amount)
- {
- $data = [
- 'out_trade_no' => $params['join_pay_order_id'],
- 'refund_amount' => $amount,
- 'out_request_no' => $params['order_id']
- ];
- Log::error("支付宝退款参数", $data);
- try {
- $res = Pay::alipay(config('payment.alipay'))->refund($data);
- $resArray = json_decode($res, true);
- if ($resArray['fund_change'] != 'Y' || $resArray['msg'] != 'Success') {
- Log::channel('pay')->error('ALIPAY_REFUND_FAIL', $resArray);
- throw new BusinessException("退款失败");
- }
- return $resArray;
- } catch (\Exception $e) {
- Log::error("支付宝退款失败", ['msg' => $e->getMessage()]);
- throw new BusinessException("退款失败");
- }
- }
- /**
- * @Desc 更新主订单
- * @Author Gorden
- * @Date 2024/8/20 14:56
- *
- * @param $order
- * @param $amount
- * @param $remark
- * @return void
- * @throws BusinessException
- */
- private function updateMainOrderByRefund($order, $amount, $remark)
- {
- $orderDiscountJson = [];
- if (!empty($order->order_discount_json)) {
- $orderDiscountJson = json_decode($order->order_discount_json, true);
- }
- try {
- $orderDiscountJson[date('Y-m-d H:i:s')] = [
- 'coupon_id' => null,
- 'coupon_value' => $amount,
- 'coupon_classify' => '退款',
- 'coupon_detail_id' => [$remark]
- ];
- $order->order_discount_json = json_encode($orderDiscountJson, JSON_UNESCAPED_UNICODE);
- $order->order_is_complete = 'R';
- $order->order_category = 'RETURN';
- // $order->order_amount_pay = $order->order_amount_pay - $amount;
- $order->save();
- } catch (\Exception $e) {
- throw new BusinessException("退款失败");
- }
- }
- /**
- * @Desc
- * @Author Gorden
- * @Date 2024/8/20 13:51
- *
- * @param $order
- * @return int
- * @throws BusinessException
- */
- private function createReturnRecord($order, $amount, $remark)
- {
- try {
- return OrderReturn::insertGetId([
- 'join_order_return_user_id' => JwtToken::getCurrentId(),
- 'join_return_member_id' => $order->join_order_member_id,
- 'join_return_order_id' => $order->order_id,
- 'order_return_status' => 'DONE',
- 'order_return_category' => '退款',
- 'order_return_apply_datetime' => date('Y-m-d H:i:s'),
- 'order_return_apply_json' => json_encode(['reason' => '后台自定义退款', 'amount' => $amount]),
- 'order_return_accept_datetime' => date('Y-m-d H:i:s'),
- 'order_return_refund_json' => json_encode(['amount' => $amount, 'user_id' => JwtToken::getCurrentId(), 'datetime' => date('Y-m-d H:i:s'), 'remark' => $remark ?? '']),
- 'order_return_addtimes' => time()
- ]);
- } catch (\Exception $e) {
- throw new BusinessException("创建退款信息失败");
- }
- }
- private function createReturnPayDetail($order, $refundPayIds, $prepayid, $amount, $response = [])
- {
- try {
- return PayDetail::insert([
- 'join_pay_member_id' => $order->join_order_member_id,
- 'join_pay_order_id' => $order->order_groupby,
- 'pay_status' => 'SUCCESS',
- 'pay_category' => 'REFUND',
- 'pay_amount' => $amount,
- 'pay_paytimes' => date('Y-m-d H:i:s'),
- 'pay_prepayid' => $prepayid,
- 'join_pay_object_json' => json_encode(['order_id' => $order->order_id, 'refund_pay_ids' => $refundPayIds]),
- 'pay_json_request' => json_encode(['order_id' => $order->order_id]),
- 'pay_json_response' => json_encode($response),
- 'pay_addtimes' => time()
- ]);
- } catch (\Exception $e) {
- }
- }
- /**
- * @Desc 充值退款详情
- * @Author Gorden
- * @Date 2024/10/16 11:40
- *
- * @param Request $request
- * @return Response
- */
- // public function rechargeSheet(Request $request)
- // {
- // $refundId = $request->get('return_id');
- // if (!$refundId) {
- // return json_fail("参数异常");
- // }
- //
- // $refund = OrderReturn::where('orders_return_id', $refundId)
- // ->first();
- // if (!empty($refund->order_return_apply_json)) {
- // $refund->order_return_apply_json = json_decode($refund->order_return_apply_json);
- // }
- //
- //
- // return json_success('', $refund);
- // }
- /**
- * @Desc 充值退款
- * @Author Gorden
- * @Date 2024/10/16 11:42
- *
- * @param Request $request
- * @return Response
- */
- public function rechargeRefund(Request $request)
- {
- $memberId = $request->post('member_id');
- $refundId = $request->post('return_id');
- $password = $request->post('refund_password', '');
- if (!$memberId) {
- return json_fail('参数异常');
- }
- if ($password != '123456') {
- return json_fail('支付密码错误');
- }
- $returnOrder = OrderReturn::where('orders_return_id', $refundId)
- ->where('join_return_member_id', $memberId)
- ->where('order_return_status', 'DOING')
- ->where('order_return_category', '会员退款')
- ->first();
- if (!$returnOrder) {
- return json_fail("退款数据异常");
- }
- $memberAccount = MemberAccount::where('join_account_member_id', $memberId)
- ->where('member_account_classify', 'CASH')
- ->where('member_account_status', 'ACTIVED')
- ->first();
- if (!$memberAccount) {
- return json_fail('会员账户异常');
- }
- try {
- Db::beginTransaction();
- $refundApplyJson = json_decode($returnOrder->order_return_apply_json, true);
- // 应减金额等于 扣除金额 + 银行打款金额
- $amount = $refundApplyJson['surplus'] + $refundApplyJson['amount'];
- $addedAmount = $refundApplyJson['added'];
- $refundApplyJson['added_amount'] = $addedAmount;
- $refundApplyJson['user_id'] = JwtToken::getCurrentId();
- $refundApplyJson['datetime'] = date('Y-m-d H:i:s');
- $refundApplyJson['remark'] = $request->post('refund_remark', '');
- $returnOrder->order_return_refund_json = json_encode($refundApplyJson);
- $returnOrder->order_return_status = 'DONE';
- $returnOrder->order_return_remark = $request->post('refund_remark', '');
- $returnOrder->save();
- // 账户剩余
- if ($memberAccount->member_account_surplus < $amount) {
- throw new BusinessException("账户本金余额不足");
- }
- if ($memberAccount->member_account_added < $addedAmount) {
- throw new BusinessException("账户增值余额不足");
- }
- // 本金
- $memberAccount->member_account_surplus = $memberAccount->member_account_surplus - $amount;
- // 增值
- $memberAccount->member_account_added = $memberAccount->member_account_added - $addedAmount;
- $memberAccount->member_account_update_user_id = JwtToken::getCurrentId();
- $memberAccount->member_account_updatetimes = time();
- $memberAccount->save();
- // 删除会员身份
- Member::where('member_id', $memberId)
- ->update([
- 'join_member_role_id' => '',
- 'member_role_begintime' => '',
- 'member_role_config_json' => '[]'
- ]);
- // 没用的优惠券失效
- CouponDetail::where('join_coupon_detail_member_id', $memberId)
- ->where('coupon_detail_status', '<>', 'USED')
- ->whereJsonContains('coupon_detail_extend_json->gettype', 'ROLE')
- ->update([
- 'coupon_detail_status' => 'DISABLED'
- ]);
- // 产生两条退款记录 (pay_detail)
- $payDetailInsertData = [
- 'join_pay_member_id' => $memberId,
- 'join_pay_order_id' => 'ROLE_REFUND',
- 'join_pay_object_json' => '[]',
- 'pay_status' => 'SUCCESS',
- 'pay_category' => 'ROLE_REFUND',
- 'pay_amount' => $refundApplyJson['amount'],
- 'pay_paytimes' => date('Y-m-d H:i:s'),
- 'pay_prepayid' => $memberId . '-CASH',
- 'pay_addtimes' => time()
- ];
- // 退款记录
- PayDetail::insert($payDetailInsertData);
- // 扣除记录
- $payDetailInsertData['join_pay_order_id'] = 'ROLE_DEDUCT';
- $payDetailInsertData['pay_category'] = 'ROLE_DEDUCT';
- $payDetailInsertData['pay_amount'] = $refundApplyJson['surplus'] + $addedAmount;
- PayDetail::insert($payDetailInsertData);
- Db::commit();
- return json_success('success');
- } catch (BusinessException $e) {
- Db::rollBack();
- return json_fail($e->getMessage());
- } catch (\Exception $e) {
- Db::rollBack();
- return json_fail('退款失败');
- }
- }
- }
|