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

app/controller/admin/order/Order.php

@@ -354,70 +354,70 @@ class Order extends BaseController
             $payVr = $this->getValue('user_sign_vr', ['order_id' => $order_id, 'type' => 2,], 'number');
             $this->backupAndDelete('user_sign_vr', ['order_id' => $order_id]);
  //           取出购买赠送积分 / 支出积分
-                $score = $this->getValue('user_sign_score', ['order_id' => $order_id, 'status' => 1,'source_type' => 3,'uid' => $uid,'pm' => 1], 'reward_score');
-                $payScore = $this->getValue('user_sign_score', ['order_id' => $order_id, 'status' => 1,'pm' => 2,'uid' => $uid,], 'reward_score');
+                $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],
-//                ['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');
+            $spreadScore = $this->getValue('user_sign_score', [
+                ['order_id', '=', $order_id],
+                ['status', '=', 1],
+                ['pm', '=', 2],
+                ['source_type', '=', 3],
+                ['mark', 'like', '%推广%'],
+            ], 'reward_socre');
+            $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表
-//            $user = Db::name('user')->where('uid', $uid)->find();
-//            if ($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) {
-//                Db::name('backup_user')->insert($spreadUserTwo);
-//            }
-//            Db::name('user')->where('uid', $spreadYongJinTwoUid)->dec('brokerage_price', $spreadYongJinTwo)->update();
+           $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表
+            $user = Db::name('user')->where('uid', $uid)->find();
+            if ($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) {
+                Db::name('backup_user')->insert($spreadUserTwo);
+            }
+            Db::name('user')->where('uid', $spreadYongJinTwoUid)->dec('brokerage_price', $spreadYongJinTwo)->update();
             Db::commit();
         } catch (\Exception $e) {
             Db::rollback();