后台-订单-撤回订单列表,撤回撤回订单

app/controller/admin/order/Order.php

@@ -346,16 +346,16 @@ class Order extends BaseController
             Db::startTrans();
             //查找是否有推荐人
             $spreadUid = Db::name('user')->where('uid', $uid)->value('spread_uid');
-            //取出并删除 pv
+            //取出pv
             $pv = $this->getValue('user_pv_log', [['order_id', '=', $order_id], ['status', '=', 1],], 'pv');
-            //取出 vr 消耗
+            //取出 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], ['pm', '=', 1],], 'reward_socre');
             $payScore = $this->getValue('user_sign_score', [['order_id', '=', $order_id], ['status', '=', 1], ['pm', '=', 2], ['uid', '=', $uid],], 'reward_socre');
             // 贡献值
             $gongXian = $this->getValue('user_sign_gongxian', [['order_id', '=', $order_id], ['status', '=', 1], ['type', '=', 1], ['uid', '=', $uid],], 'number');
-            // 养老金 / 推广养老金 / 推广佣金
+            // 养老金
             $yangLaoJin = $this->getValue('user_bill', [['link_id', '=', $order_id], ['status', '=', 1], ['pm', '=', 1], ['uid', '=', $uid],], 'number');
             if($spreadUid){
                 $spreadScore = 0;
@@ -368,38 +368,78 @@ class Order extends BaseController
                 $spreadYongJin = $this->getValue('user_bill', [['link_id', '=', $order_id], ['commission_type', '=', 3], ['uid', '=', $spreadUid],], 'number');  //推荐获得佣金
                 $spreadUser = Db::name('user')->where('uid', $spreadUid)->find();
                 Db::name('backup_user')->insert($spreadUser);
-                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', $spreadUid)
+                    ->update([
+                        'score' => Db::raw("score - {$spreadScore}"),
+                        'per_contribute' => Db::raw("per_contribute - {$spreadGongXian}"),
+                        'brokerage_price' => Db::raw("brokerage_price - {$spreadYongJin}"),
+                        'annuity' => Db::raw("annuity - {$spreadYlj}"),
+                    ]);
+                $userhjm1 =[
+                    'uid' => $spreadUid,
+                    'order_id' => $order_id,
+                    'score' => $spreadScore,
+                    'per_contribute' => $spreadGongXian,
+                    'brokerage_price' => $spreadYongJin,
+                    'user' => 2,
+                ];
+                Db::name('backup_user_change')->insert($userhjm1);
             }
             //扫吗消费
             $smSpreadUid = $this->getValue('user_sign_score', [['order_id', '=', $order_id], ['mark','like','%扫码%'], ['status', '=', 1],], 'uid');
             $smSpreadScore = $this->getValue('user_sign_score', [['order_id', '=', $order_id], ['uid','=',$smSpreadUid], ['status', '=', 1],], 'reward_socre');
             //第二推荐
-            $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');
+            $spreadYongJinTwoUid = $this->getValue('user_bill', [['link_id', '=', $order_id], ['commission_type', '=', 3], ['uid', 'not in', [$uid, $spreadUid]],], 'uid');
+            $spreadYongJinTwo = $this->getValue('user_bill', [['link_id', '=', $order_id], ['commission_type', '=', 3], ['uid', '=', $spreadYongJinTwoUid],], 'number');
             //更新对应的user表
+            $uscore = $payScore - $score;
             $user = Db::name('user')->where('uid', $uid)->find();
             Db::name('backup_user')->insert($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();
+            Db::name('user')->where('uid', $uid)
+                ->update([
+                    'pv'         => Db::raw("pv - {$pv}"),
+                    'vr'         => Db::raw("vr + {$payVr}"),
+                    'score'      => Db::raw("score + {$uscore}"),
+                    'contribute' => Db::raw("contribute - {$gongXian}"),
+                    'annuity'    => Db::raw("annuity - {$yangLaoJin}"),
+                ]);
+            $userhjm =[
+                'uid' => $uid,
+                'order_id' => $order_id,
+                'pv' => $pv,
+                'vr' => $payVr,
+                'score' => $uscore,
+                'contribute' => $gongXian,
+                'annuity' => $yangLaoJin,
+                'user' => 1,
+            ];
+            Db::name('backup_user_change')->insert($userhjm);//具体修改插入对应表
             //第二推荐
             if($spreadYongJinTwoUid) {
                 $spreadUserTwo = Db::name('user')->where('uid', $spreadYongJinTwoUid)->find();
                 Db::name('backup_user')->insert($spreadUserTwo);
                 Db::name('user')->where('uid', $spreadYongJinTwoUid)->dec('brokerage_price', $spreadYongJinTwo)->update();
-            }
+                $userhjm2 =[
+                    'uid' => $spreadYongJinTwoUid,
+                    'order_id' => $order_id,
+                    'brokerage_price' => $spreadYongJinTwo,
+                    'user' => 3,
+                ];
+                Db::name('backup_user_change')->insert($userhjm2);
+            }//扫码消费
             if($smSpreadUid){
                 $smUserTwo = Db::name('user')->where('uid', $smSpreadUid)->find();
                 Db::name('backup_user')->insert($smUserTwo);
                 Db::name('user')->where('uid', $smSpreadUid)->dec('score', $smSpreadScore)->update();
+                $userhjm3 =[
+                    'uid' => $smSpreadUid,
+                    'order_id' => $order_id,
+                    'score' => $smSpreadScore,
+                    'user' => 4,
+                ];
+                Db::name('backup_user_change')->insert($userhjm3);
             }
-            // 删除订单相关表
+            // 删除订单相关表p;
             $this->backupAndDelete('store_order', ['group_order_id' => $group_order_id]);
             $this->backupAndDelete('store_group_order', ['group_order_id' => $group_order_id]);
             $this->backupAndDelete('user_pv_log', ['order_id' => $order_id]);
@@ -416,7 +456,7 @@ class Order extends BaseController
         return app('json')->success('操作成功');
     }
 
-    private function backupAndDelete($table, array $where)
+    private function backupAndDelete($table, array $where)//备份并删除
     {
         $backupTable = 'backup_' . $table;
         $rows = Db::name($table)->where($where)->select()->toArray();
@@ -425,9 +465,118 @@ class Order extends BaseController
             Db::name($table)->where($where)->delete();
         }
     }
-    private function getValue($table, array $where, string $field, $default = 0)
+    private function getValue($table, array $where, string $field, $default = 0)//查找
     {
         $value = Db::name($table)->where($where)->value($field);
         return $value ?? $default;
     }
+
+    /**
+     * 展示撤回订单列表
+     */
+    public function killOrderLst()
+    {
+        $query = Db::name('backup_store_order')->paginate(20)->toArray();
+        return app('json')->success($query, '获取成功');
+    }
+    public function easterKillOrder(){
+        $group_order_id = request()->param('group_order_id');
+        $order_id = request()->param('order_id');
+        if (empty($order_id) || empty($group_order_id)) {
+            return app('json')->fail('参数缺失');
+        }
+        try {
+            Db::startTrans();
+            // 恢复订单相关表
+            $this->easterOrder('store_order', ['group_order_id' => $group_order_id]);
+            $this->easterOrder('store_group_order', ['group_order_id' => $group_order_id]);
+            // 恢复 pv
+            $this->easterOrder('user_pv_log', ['order_id' => $order_id]);
+            // 恢复 vr
+            $this->easterOrder('user_sign_vr', ['order_id' => $order_id]);
+            // 恢复 积分
+            $this->easterOrder('user_sign_score', ['order_id' => $order_id]);
+            // 恢复 贡献值
+            $this->easterOrder('user_sign_gongxian', ['order_id' => $order_id]);
+            // 恢复 佣金/养老金等
+            $this->easterOrder('user_bill', ['link_id' => $order_id]);
+            // 恢复 公证处
+            $this->easterOrder('gzc_logs', ['link_id' => $order_id]);
+            //恢复用户奖励
+            $this->easterOrder('user_change', ['order_id' => $order_id]);
+            Db::commit();
+        } catch (\Exception $e) {
+            Db::rollback();
+            return app('json')->fail('撤回失败: '.$e->getMessage());
+        }
+        return app('json')->success('撤回成功');
+    }
+
+    private function easterOrder($table, array $where)
+    {
+        $backupTable = 'backup_' . $table;
+        $rows = Db::name($backupTable)->where($where)->select()->toArray();
+        if ($rows) {
+            foreach ($rows as &$row) {
+                unset($row['backup_time']);
+            }
+            Db::name($table)->insertAll($rows);
+            Db::name($backupTable)->where($where)->delete();
+        }
+    }
+    private function easterUserAward($table, array $where){
+        $backupTable = 'backup_' . $table;
+        $row = Db::name($backupTable)->where($where)->where('user', 1)->field('pv, vr, score, contribute, annuity,uid')->find();
+        $uid = $row['uid'];
+        $pv   = $row['pv'];
+        $vr   = $row['vr'];
+        $score= $row['score'];
+        $contribute = $row['contribute'];
+        $annuity = $row['annuity'];
+        Db::name('user') //更新订单用户
+            ->where('uid', $uid)
+            ->update([
+                'pv'         => Db::raw("pv + {$pv}"),
+                'vr'         => Db::raw("vr - {$vr}"),
+                'score'      => Db::raw("score - {$score}"),
+                'contribute' => Db::raw("contribute + {$contribute}"),
+                'annuity'    => Db::raw("annuity + {$annuity}"),
+            ]);
+        $row2 = Db::name($backupTable)->where($where)->where('user', 2)->field('brokerage_price, score, per_contribute, annuity,uid')->find();
+        if ($row2) {
+            $spreadUid = $row2['uid'];
+            $spreadScore = $row2['score'];
+            $per_contribute = $row2['per_contribute'];
+            $spreadAnnuity = $row2['annuity'];
+            $spreadYongJin = $row2['brokerage_price'];
+            Db::name('user')     //更新推荐人
+            ->where('uid', $spreadUid)
+                ->update([
+                    'score' => Db::raw("score + {$spreadScore}"),
+                    'contribute' => Db::raw("contribute + {$per_contribute}"),
+                    'annuity' => Db::raw("annuity + {$spreadAnnuity}"),
+                    'brokerage_price' => Db::raw("brokerage_price + {$spreadYongJin}"),
+                ]);
+        }
+        $row3 = Db::name($backupTable)->where($where)->where('user', 3)->field('brokerage_price,uid')->find();
+        if ($row3) {
+            $spreadUidTwo = $row3['uid'];
+            $spreadYongJin2 = $row3['brokerage_price'];
+            Db::name('user')
+                ->where('uid', $spreadUidTwo)
+                ->update([
+                    'brokerage_price' => Db::raw("brokerage_price + {$spreadYongJin2}"),
+                ]);
+        }
+        $row4 = Db::name($backupTable)->where($where)->where('user', 4)->field('score,uid')->find();
+        if ($row4) {
+            $spreadUidThree = $row4['uid'];
+            $spreadScore3 = $row4['score'];
+            Db::name('user')
+                ->where('uid', $spreadUidThree)
+                ->update([
+                    'score' => Db::raw("score + {$spreadScore3}"),
+                ]);
+        }
+    }
 }

route/admin.php

@@ -973,7 +973,9 @@ Route::group(config('admin.api_admin_prefix') . '/', function () {
             Route::get('dhm_list/lst', 'RefundOrder/dhm_list')->name('systemRefundOrderDhmLst');
             Route::get('dhm_status', 'RefundOrder/dhm_status')->name('systemRefundOrderDhmStatus');
             Route::get('excel', 'Order/Excel')->name('systemOrderExcel');
-            Route::post('killOrderRewards', 'Order/killOrderRewards');
+            Route::post('killOrderRewards', 'Order/killOrderRewards');//撤回订单
+            Route::post('killOrderLst', 'Order/killOrderLst');//撤回订单的列表
+            Route::post('easterKillOrder', 'Order/easterKillOrder');//撤回撤回订单
         })->prefix('admin.order.');
 
         //第三方订单