where(['is_delete'=> 2,'delete_time'=> ['<>', 0]])->select(); if($res){ foreach ($res as $v){ //删除动态下的标签引用 $top_zone = db::name('user_zone_topic')->where('zone_id',$v['id'])->select(); if($top_zone){ foreach ($top_zone as $vs){ db::name('user_zone_topic')->where('id',$vs['id'])->delete(); } } } } } //测试数据 public function testData() { $res = db::name('vs_user_gift_pack') ->field('gid,after_num') ->where(['a.updatetime'=> ['<=', 1766332800]]) ->group('a.gid') ->select(); $total_price = 0; if($res){ foreach ($res as $v){ $gft_price = db::name('vs_gift')->where('gid',$v['gid'])->value('gift_price'); $total_price += $gft_price * $v['after_num']; } } echo $total_price; echo '
'; var_dump($res); } //拆分钱包表 public function splitWallet() { $res = db::name('user_wallet')->field('user_id,coin,earnings,createtime')->select(); $coin_data = []; $earnings_data = []; $i = 0; if($res){ foreach ($res as $v){ $coin_data[] = [ 'user_id' => $v['user_id'], 'coin' => $v['coin'], 'createtime' => $v['createtime'], ]; $earnings_data[] = [ 'user_id' => $v['user_id'], 'earnings' => $v['earnings'], 'createtime' => $v['createtime'], ]; $i++; } $res = db::name('user_wallet_coin')->insertAll($coin_data); $res1 = db::name('user_wallet_earnings')->insertAll($earnings_data); echo $i.'条数据成功插入'.$res.'===='.$res1; } } //拆分流水表 public function splitFlow() { $page = input('page'); if(!$page){ echo '请输入页数';exit; } $res = db::name('vs_user_money_log')->where('exp',0) ->field('log_id,user_id,room_id,change_type,money_type,change_value,from_id,remarks,createtime') ->page($page,10000) // ->where(['createtime'=> ['>=', 1765728000]]) ->select(); $i = 0; if($res){ foreach ($res as $k => $v){ $coin_data = []; $ear_data = []; if($v['money_type'] ==1){ $coin_data = [ 'user_id' => $v['user_id'], 'room_id' => $v['from_id'], 'coin' => $v['change_value'], 'before' => $v['change_value'], 'after' => $v['change_value'], 'change_type' => $v['change_type'], 'remarks' => $v['remarks'], ]; } if($v['money_type'] ==2){ $ear_data = [ 'user_id' => $v['user_id'], 'room_id' => $v['from_id'], 'earnings' => $v['change_value'], 'before' => $v['change_value'], 'after' => $v['change_value'], 'remarks' => $v['remarks'], 'change_type' => $v['change_type'], ]; } $res = db::name('user_coin_log')->insert($coin_data); $res1 = db::name('user_earnings_log')->insert($ear_data); db::name('vs_user_money_log')->where('log_id',$v['log_id'])->update(['exp'=>1]); $i ++; } echo $i.'条数据成功插入'; } } }