Explorar el Código

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

xupuyuan hace 10 meses
padre
commit
a878834fe2
Se han modificado 1 ficheros con 12 adiciones y 0 borrados
  1. 12 0
      app/controller/admin/order/Order.php

+ 12 - 0
app/controller/admin/order/Order.php

@@ -380,6 +380,10 @@ class Order extends BaseController
380
             $this->backupAndDelete('user_bill', ['link_id' => $order_id]);
380
             $this->backupAndDelete('user_bill', ['link_id' => $order_id]);
381
             $this->backupAndDelete('gz_logs', ['link_id' => $order_id]);
381
             $this->backupAndDelete('gz_logs', ['link_id' => $order_id]);
382
             //更新对应的user表
382
             //更新对应的user表
383
+            $user = Db::name('user')->where('uid', $uid)->find();
384
+            if ($user) {
385
+                Db::name('backup_user')->insert($user);
386
+            }
383
             Db::name('user')->where('uid', $uid)->dec('pv', $pv)->update();
387
             Db::name('user')->where('uid', $uid)->dec('pv', $pv)->update();
384
             Db::name('user')->where('uid', $uid)->inc('vr', $payVr)->update();
388
             Db::name('user')->where('uid', $uid)->inc('vr', $payVr)->update();
385
             Db::name('user')->where('uid', $uid)->inc('score', $payScore)->update();
389
             Db::name('user')->where('uid', $uid)->inc('score', $payScore)->update();
@@ -387,11 +391,19 @@ class Order extends BaseController
387
             Db::name('user')->where('uid', $uid)->dec('contribute', $gongXian)->update();
391
             Db::name('user')->where('uid', $uid)->dec('contribute', $gongXian)->update();
388
             Db::name('user')->where('uid', $uid)->dec('annuity', $yangLaoJin)->update();
392
             Db::name('user')->where('uid', $uid)->dec('annuity', $yangLaoJin)->update();
389
             //推荐人user表
393
             //推荐人user表
394
+            $spreadUser = Db::name('user')->where('uid', $spreadUid)->find();
395
+            if ($spreadUser) {
396
+                Db::name('backup_user')->insert($spreadUser);
397
+            }
390
             Db::name('user')->where('uid', $spreadUid)->dec('score', $spreadScore)->update();
398
             Db::name('user')->where('uid', $spreadUid)->dec('score', $spreadScore)->update();
391
             Db::name('user')->where('uid', $spreadUid)->dec('per_contribute', $spreadGongXian)->update();
399
             Db::name('user')->where('uid', $spreadUid)->dec('per_contribute', $spreadGongXian)->update();
392
             Db::name('user')->where('uid', $spreadUid)->dec('annuity', $spreadYlj)->update();
400
             Db::name('user')->where('uid', $spreadUid)->dec('annuity', $spreadYlj)->update();
393
             Db::name('user')->where('uid', $spreadUid)->dec('brokerage_price', $spreadYongJin)->update();
401
             Db::name('user')->where('uid', $spreadUid)->dec('brokerage_price', $spreadYongJin)->update();
394
             //第二个推荐人
402
             //第二个推荐人
403
+            $spreadUserTwo = Db::name('user')->where('uid', $spreadYongJinTwoUid)->find();
404
+            if ($spreadUserTwo) {
405
+                Db::name('backup_user')->insert($spreadUserTwo);
406
+            }
395
             Db::name('user')->where('uid', $spreadYongJinTwoUid)->dec('brokerage_price', $spreadYongJinTwo)->update();
407
             Db::name('user')->where('uid', $spreadYongJinTwoUid)->dec('brokerage_price', $spreadYongJinTwo)->update();
396
             Db::commit();
408
             Db::commit();
397
         } catch (\Exception $e) {
409
         } catch (\Exception $e) {