130 lines
4.1 KiB
PHP
130 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()
|
|
{
|
|
$res = db::name('vs_user_money_log')
|
|
->field('user_id,room_id,change_type,money_type,change_value,from_id,remarks,createtime')->select();
|
|
$coin_data = [];
|
|
$ear_data = [];
|
|
$i = 0;
|
|
if($res){
|
|
foreach ($res as $v){
|
|
//金币类型
|
|
$in_types = [2,5,6,8,13,14,15,16,23,26,27,28,30,33,35,40,51,57,58,4,7,10,17,20,24,25,32,42,50,56,59];
|
|
|
|
//钻石类型
|
|
$in_type = [9,11,12,18,19,21,22,31,28,34,41,52,53,54,55,57,3,14,29,43];
|
|
|
|
if(in_array($v['change_type'],$in_types)){
|
|
$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(in_array($v['change_type'],$in_type)){
|
|
$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'],
|
|
];
|
|
}
|
|
$i ++;
|
|
}
|
|
|
|
$res = db::name('user_coin_log')->insertAll($coin_data);
|
|
$res1 = db::name('user_earnings_log')->insertAll($ear_data);
|
|
echo $i.'条数据成功插入'.$res.'===='.$res1;
|
|
}
|
|
}
|
|
|
|
} |