134 lines
4.1 KiB
PHP
134 lines
4.1 KiB
PHP
<?php
|
|
|
|
namespace app\api\controller;
|
|
|
|
use think\Controller;
|
|
use think\Db;
|
|
use think\Log;
|
|
|
|
use app\common\controller\Push;
|
|
|
|
class Xxiaoshi extends Controller
|
|
{
|
|
|
|
public function test()
|
|
{
|
|
$res = db::name('user_zone')->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 '<br>';
|
|
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.'条数据成功插入';
|
|
}
|
|
}
|
|
|
|
} |