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

app/controller/admin/order/Order.php

@@ -345,68 +345,69 @@ class Order extends BaseController
         try {
             Db::startTrans();
             //查找是否有推荐人
-            $spreadUid = Db::name('user')->where('uid',$uid)->value('spread_uid');
-            // 删除订单相关表 对应备份还没有创建
-            $this->backupAndDelete('store_order', ['group_order_id' => $group_order_id]);
-            $this->backupAndDelete('store_group_order', ['group_order_id' => $group_order_id]);
+            $spreadUid = Db::name('user')->where('uid', $uid)->value('spread_uid');
             //取出并删除 pv
-                $pv = $this->getValue('user_pv_log', ['order_id' => $order_id, 'status' => 1,], 'pv');
-                $this->backupAndDelete('user_pv_log', ['order_id' => $order_id]); //status状态判断还没
+            $pv = $this->getValue('user_pv_log', [['order_id', '=', $order_id], ['status', '=', 1],], 'pv');
             //取出 vr 消耗
-            $payVr = $this->getValue('user_sign_vr', ['order_id' => $order_id, 'type' => 2,], 'number');
-            $this->backupAndDelete('user_sign_vr', ['order_id' => $order_id]);
+            $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');
-            // 取出推广赠送的积分和推广人的 uid
-            $spreadScore = $this->getValue('user_sign_score', ['order_id', '=', $order_id, 'uid', '=', $spreadUid, 'status', '=', 1,], 'reward_socre');
-            // 删除所有相关积分记录
-            $this->backupAndDelete('user_sign_score', ['order_id' => $order_id]);
+            $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');
-            $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]);
+            $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');
-            $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');  //推荐获得佣金
+            $yangLaoJin = $this->getValue('user_bill', [['link_id', '=', $order_id], ['status', '=', 1], ['pm', '=', 1], ['uid', '=', $uid],], 'number');
+            if($spreadUid){
+                $spreadScore = 0;
+                $spreadGongXian = 0;
+                $spreadYlj = 0;
+                $spreadYongJin = 0;
+                $spreadScore = $this->getValue('user_sign_score', [['order_id', '=', $order_id], ['uid', '=', $spreadUid], ['status', '=', 1],], 'reward_socre');
+                $spreadGongXian = $this->getValue('user_sign_gongxian', [['order_id', '=', $order_id], ['status', '=', 1], ['type', '=', 1], ['uid', '=', $spreadUid],], 'number');
+                $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');  //推荐获得佣金
+                $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();
             }
-            $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]);
+            //扫吗消费
+            $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');
             //更新对应的user表
             $user = Db::name('user')->where('uid', $uid)->find();
-            if ($user) {
-                Db::name('backup_user')->insert($user);
-            }
+            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();
-            //推荐人user表
-            $spreadUser = Db::name('user')->where('uid', $spreadUid)->find();
-            if ($spreadUser) {
-                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();
-            //第二个推荐人
-            $spreadUserTwo = Db::name('user')->where('uid', $spreadYongJinTwoUid)->find();
-            if ($spreadUserTwo) {
+            //第二推荐
+            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();
+            }
+            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();
             }
-            Db::name('user')->where('uid', $spreadYongJinTwoUid)->dec('brokerage_price', $spreadYongJinTwo)->update();
+            // 删除订单相关表
+            $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]);
+            $this->backupAndDelete('user_sign_vr', ['order_id' => $order_id]);
+            $this->backupAndDelete('user_sign_score', ['order_id' => $order_id]);
+            $this->backupAndDelete('user_sign_gongxian', ['order_id' => $order_id]);
+            $this->backupAndDelete('user_bill', ['link_id' => $order_id]);
+            $this->backupAndDelete('gz_logs', ['link_id' => $order_id]);
             Db::commit();
         } catch (\Exception $e) {
             Db::rollback();
@@ -414,6 +415,7 @@ class Order extends BaseController
         }
         return app('json')->success('操作成功');
     }
+
     private function backupAndDelete($table, array $where)
     {
         $backupTable = 'backup_' . $table;