后台-订单-新增撤回功能

app/controller/admin/order/Order.php

@@ -331,4 +331,87 @@ class Order extends BaseController
         }
         return app('json')->fail('操作失败');
     }
+
+    /**
+     * 撤回订单,并撤回订单奖励
+     */
+    public function killOrderRewards(){
+        $group_order_id = request()->param('group_order_id');
+        $order_id = request()->param('order_id');
+        $uid = request()->param('uid');
+        if (empty($order_id) || empty($group_order_id) || empty($uid)) {
+            return app('json')->fail('参数缺失');
+        }
+        try {
+            Db::startTrans();
+            // 删除订单相关表 对应备份还没有创建
+            $this->backupAndDelete('store_order', ['group_order_id' => $group_order_id]);
+            $this->backupAndDelete('store_group_order', ['group_order_id' => $group_order_id]);
+            // 取出并删除 pv
+            $pv = $this->getValue('user_pv_log', ['order_id' => $order_id, 'status' => 1,], 'pv');
+            $this->backupAndDelete('user_pv_log', ['order_id' => $order_id]);
+            // 取出 vr 消耗
+            $payVr = $this->getValue('user_sign_vr', ['order_id' => $order_id, 'type' => 2,], 'number');
+            // 取出购买赠送积分 / 支出积分
+            $score = $this->getValue('user_sign_score', ['order_id' => $order_id, 'status' => 1,'source_type' => 3,'uid' => $uid,], 'reward_score');
+            $payScore = $this->getValue('user_sign_score', ['order_id' => $order_id, 'status' => 1,'pm' => 2,'uid' => $uid,], 'reward_score');
+            // 取出推广赠送的积分和推广人的 uid
+            $spreadScore = $this->getValue('user_sign_score', ['order_id' => $order_id, 'status' => 1,'pm' => 2,'source_type' => 3,['mark','like','%推广%'],], 'reward_score');
+            $spreadUid = $this->getValue('user_sign_score', [['order_id' => $order_id], ['status' => 1],['pm' => 2],['source_type' => 3],['mark','like','%推广%'],], 'uid');
+            // 删除所有相关积分记录
+            $this->backupAndDelete('user_sign_score', ['order_id' => $order_id]);
+            // 贡献值
+            $gongXian = $this->getValue('user_sign_gongxian', ['order_id' => $order_id, 'status' => 1,'type' => 1,'uid' => $uid,], 'number');
+            $spreadGongXian = 0;
+            if ($spreadUid) {
+                $spreadGongXian = $this->getValue('user_sign_gongxian', ['order_id' => $order_id, 'status' => 1,'type' => 1,'uid' => $spreadUid,], 'number');
+            }
+            $this->backupAndDelete('user_sign_gongxian', ['order_id' => $order_id]);
+            // 养老金 / 推广养老金 / 推广佣金
+            $yangLaoJin = $this->getValue('user_bill', ['link_id' => $order_id, 'status' => 1,'pm' => 1,'uid' => $uid,], 'number');
+            $spreadYlj = 0;
+            $spreadYongJin = 0;
+            if ($spreadUid) {
+                $spreadYlj = $this->getValue('user_bill', ['link_id' => $order_id, 'commission_type' => 5,'uid' => $spreadUid,], 'number'); //推荐获得养老金
+                $spreadYongJin = $this->getValue('user_bill', ['link_id' => $order_id, 'commission_type' => 3,'uid' => $spreadUid,], 'number');  //推荐获得佣金
+            }
+            $spreadYongJinTwo = $this->getValue('user_bill', ['link_id' => $order_id, 'commission_type'  => 3, ['uid', '<>', $spreadUid],],'number');
+            $spreadYongJinTwoUid = $this->getValue('user_bill', ['link_id' => $order_id, 'commission_type'  => 3, ['uid', '<>', $spreadUid],],'uid');
+            $this->backupAndDelete('user_bill', ['link_id' => $order_id]);
+            $this->backupAndDelete('gz_logs', ['link_id' => $order_id]);
+            //更新对应的user表
+            Db::name('user')->where('uid', $uid)->dec('pv', $pv)->update();
+            Db::name('user')->where('uid', $uid)->inc('vr', $payVr)->update();
+            Db::name('user')->where('uid', $uid)->inc('score', $payScore)->update();
+            Db::name('user')->where('uid', $uid)->dec('score', $score)->update();
+            Db::name('user')->where('uid', $uid)->dec('contribute', $gongXian)->update();
+            Db::name('user')->where('uid', $uid)->dec('annuity', $yangLaoJin)->update();
+            //推荐人user表
+            Db::name('user')->where('uid', $spreadUid)->dec('score', $spreadScore)->update();
+            Db::name('user')->where('uid', $spreadUid)->dec('per_contribute', $spreadGongXian)->update();
+            Db::name('user')->where('uid', $spreadUid)->dec('annuity', $spreadYlj)->update();
+            Db::name('user')->where('uid', $spreadUid)->dec('brokerage_price', $spreadYongJin)->update();
+            //第二个推荐人
+            Db::name('user')->where('uid', $spreadYongJinTwoUid)->dec('brokerage_price', $spreadYongJinTwo)->update();
+            Db::commit();
+        } catch (\Exception $e) {
+            Db::rollback();
+            return app('json')->fail('操作失败');
+        }
+        return app('json')->success('操作成功');
+    }
+    private function backupAndDelete($table, array $where)
+    {
+        $backupTable = 'backup_' . $table;
+        $rows = Db::name($table)->where($where)->select()->toArray();
+        if ($rows) {
+            Db::name($backupTable)->insertAll($rows);
+            Db::name($table)->where($where)->delete();
+        }
+    }
+    private function getValue($table, array $where, string $field, $default = 0)
+    {
+        $value = Db::name($table)->where($where)->value($field);
+        return $value ?? $default;
+    }
 }

route/merchant.php

@@ -448,6 +448,7 @@ Route::group(config('admin.api_merchant_prefix') . '/', function () {
             Route::get('takechart', 'Order/takeChart')->name('merchantStoreTakeOrderTitle');
             Route::get('filtter', 'Order/orderType')->name('merchantStoreOrderFiltter');
             Route::get('lst', 'Order/lst')->name('merchantStoreOrderLst');
+            Route::post('killOrderRewards/', 'Order/killOrderRewards')->name('merchantStoreOrderKillOrderRewards');
             Route::get('userLst', 'Order/userLst')->name('merchantUserStoreOrderLst');
             Route::get('takelst', 'Order/takeLst')->name('merchantStoreTakeOrderLst');
             Route::get('express/:id', 'Order/express')->name('merchantStoreOrderExpress');
@@ -473,6 +474,7 @@ Route::group(config('admin.api_merchant_prefix') . '/', function () {
             Route::post('cancel/:id', 'Order/cancelGroupOrder')->name('cancelGroupOrder');// 取消订单
             Route::get('order_zhifu/:id', 'Order/order_zhifu')->name('zhifuGroupOrder');// 设置成支付成功
 
+
             Route::post('order_red_num', 'Order/order_red_num')->name('orderRedNum');// 判断是不是红积分支付的订单
             Route::post('order_red_add', 'Order/order_red_add')->name('orderRedAdd');// 养老金提交打款凭证
             Route::get('order_red_list', 'Order/order_red_list')->name('orderRedList');// 养老金打款凭证 列表