|
@@ -97,38 +97,27 @@ class Userwithdraw extends Backend
|
|
|
|
|
|
//2不能再给他加钱
|
|
//2不能再给他加钱
|
|
|
|
|
|
- //3他的上下级自动衔接,他自身掉落到底
|
|
|
|
- $user = Db::name('user')->where('id',$info['user_id'])->lock(true)->find();
|
|
|
|
|
|
+ //3他的上下级自动衔接
|
|
|
|
+ $user = Db::name('user')->where('id',$info['user_id'])->find();
|
|
|
|
+
|
|
|
|
|
|
- $commonuser = new \app\common\model\User;
|
|
|
|
//我的多个下级,的推荐人,改成我的上级。也就是跳过了我
|
|
//我的多个下级,的推荐人,改成我的上级。也就是跳过了我
|
|
$my_down = Db::name('user')->where('intro_uid',$user['id'])->select();
|
|
$my_down = Db::name('user')->where('intro_uid',$user['id'])->select();
|
|
// dump($my_down);
|
|
// dump($my_down);
|
|
if(!empty($my_down)){
|
|
if(!empty($my_down)){
|
|
- foreach($my_down as $key => $down_user){
|
|
|
|
- $rs_down = $commonuser->updateIntro($down_user['id'],$user['intro_uid']);
|
|
|
|
- if($rs_down !== true){
|
|
|
|
- Db::rollback();
|
|
|
|
- $this->error($rs_down);
|
|
|
|
- }
|
|
|
|
|
|
+
|
|
|
|
+ $new_intro_uid = $user['intro_uid'] ?: 0;
|
|
|
|
+ $rs_down = Db::name('user')->where('intro_uid',$user['id'])->update(['intro_uid'=>$new_intro_uid]);
|
|
|
|
+ if($rs_down === false){
|
|
|
|
+ Db::rollback();
|
|
|
|
+ $this->error('操作失败');
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- //理论上已经用不到了,预防万一又被查到
|
|
|
|
- //我滑落了,我的上级保持不变,下级都没了
|
|
|
|
- $my_update = [
|
|
|
|
- 'intro_num' => 0,
|
|
|
|
- 'intro_num_all' => 0,
|
|
|
|
- ];
|
|
|
|
- $rs2 = Db::name('user')->where('id',$user['id'])->update($my_update);
|
|
|
|
- if($rs2 === false){
|
|
|
|
- Db::rollback();
|
|
|
|
- $this->error('更新自己错误');
|
|
|
|
- }
|
|
|
|
|
|
|
|
//记录个日志
|
|
//记录个日志
|
|
$log = [
|
|
$log = [
|
|
- 'info' => '用户['.$user['id'].']因提现而滑落,其名下直推有['.implode(',',array_column($my_down,'id')).'],都改到其上级['.$user['intro_uid'].']名下',
|
|
|
|
|
|
+ 'info' => '用户['.$user['id'].']因提现,其名下直推有['.implode(',',array_column($my_down,'id')).'],都改到其上级['.$user['intro_uid'].']名下',
|
|
'createtime' => time(),
|
|
'createtime' => time(),
|
|
];
|
|
];
|
|
Db::name('intro_log')->insertGetId($log);
|
|
Db::name('intro_log')->insertGetId($log);
|