Merge remote-tracking branch 'origin/develop' into develop

This commit is contained in:
2025-09-03 18:16:19 +08:00
5 changed files with 63 additions and 49 deletions

View File

@@ -8,10 +8,11 @@ class Friend extends BaseCom
{ {
//交友开始 //交友开始
public function start_friend(){ public function start_friend(){
$key_name = "api:friend:start_friend:" . $this->uid;
redis_lock_exits($key_name);
$room_id = input('room_id', ''); $room_id = input('room_id', '');
$reslut = model('Friend')->start_friend($this->uid,$room_id); $reslut = model('Friend')->start_friend($this->uid,$room_id);
redis_unlocks($key_name);
return V($reslut['code'], $reslut['msg'], $reslut['data']); return V($reslut['code'], $reslut['msg'], $reslut['data']);
} }
@@ -40,14 +41,15 @@ class Friend extends BaseCom
//卡关系 创建关系 //卡关系 创建关系
public function create_relation() public function create_relation()
{ {
$key_name = "api:friend:create_relation:" . $this->uid;
redis_lock_exits($key_name);
$room_id = input('room_id', ''); $room_id = input('room_id', '');
$friend_id = input('friend_id', ''); $friend_id = input('friend_id', '');
$user1_id = input('user1_id', ''); $user1_id = input('user1_id', '');
$user2_id = input('user2_id', ''); $user2_id = input('user2_id', '');
$relation_id = input('relation_id', ''); $relation_id = input('relation_id', '');
$result = model('Friend')->createRelation($this->uid,$room_id,$friend_id,$user1_id,$user2_id,$relation_id); $result = model('Friend')->createRelation($this->uid,$room_id,$friend_id,$user1_id,$user2_id,$relation_id);
redis_unlocks($key_name);
return V($result['code'], $result['msg'], $result['data']); return V($result['code'], $result['msg'], $result['data']);
} }

View File

@@ -157,44 +157,46 @@ class Friend extends Model
$originalPairs = db::name('vs_user_friending_heart') $originalPairs = db::name('vs_user_friending_heart')
->where(['id'=>$friending_heart['id']]) ->where(['id'=>$friending_heart['id']])
->update(['status' => 3,'friend_config_id' =>$friending_config_id]); ->update(['status' => 3,'friend_config_id' =>$friending_config_id]);
$msg = '';
if ($originalPairs) { if ($originalPairs) {
$relation = db::name('vs_relation')->where('id',$friending_config_id)->value('name'); $relation = db::name('vs_relation')->where('id',$friending_config_id)->value('name');
if($friending_heart['heart_value'] >= get_system_config_value('friend_heart_create_room') && $friending_config_id > 0){ if($friending_heart['heart_value'] >= get_system_config_value('friend_heart_create_room') && $friending_config_id > 0){
//创建小房间 //创建小房间
$room_ids = model('api/Room')->user_create_room($user1,'的电影房',get_system_config_value('web_site').'/data/avatar/head_pic.png','交友房产生的一次性房间',7); $room_ids = model('api/Room')->user_create_room($user1,'的电影房',get_system_config_value('web_site').'/data/avatar/head_pic.png','交友房产生的一次性房间',7);
if($room_ids['code'] != 1){ if($room_ids['code'] != 1){
//推送给前端消息 $msg = 'cp电影房创建失败';
$text['text'] = '交友结束'; // //推送给前端消息
$text['step'] = 1;//1 等待邂逅 2 心动连线 3 牵手良缘 // $text['text'] = '交友结束';
model('api/Chat')->sendMsg(1049,$room_id,$text); // $text['step'] = 1;//1 等待邂逅 2 心动连线 3 牵手良缘
db::rollback(); // model('api/Chat')->sendMsg(1049,$room_id,$text);
return ['code' => 0, 'msg' => 'cp电影房创建失败请联系管理员','data' => null]; // db::rollback();
} // return ['code' => 0, 'msg' => 'cp电影房创建失败请联系管理员','data' => null];
}else{
//记录小房间
$datda = [
'room_id' => $room_ids['data'],
'relation_id' => $friending_config_id,
'user_id' => $user1,
'user_id1' => $user2,
'time_day' => time() + get_system_config_value('friend_room_timea') * 60,
'createtime' => time(),
'status' => 1,
'type' => 1
];
db::name('vs_room_cp_movie')->insert($datda);
//记录小房间 if($room_ids['data']){
$datda = [ $text['text'] = '交友结束并创建房间';
'room_id' => $room_ids['data'], $text['relation_name'] = $relation;
'relation_id' => $friending_config_id, $text['room_id'] = $room_ids['data'];//前端用来让用户跳转的房间id
'user_id' => $user1, $text['user1_id'] = $user1;//进小房间的用户id
'user_id1' => $user2, $text['user2_id'] = $user2;//进小房间的用户id
'time_day' => time() + get_system_config_value('friend_room_timea') * 60, $text['user1_avatar'] = db::name('user')->where(['id'=>$user1])->value('avatar');
'createtime' => time(), $text['user1_nickname'] = db::name('user')->where(['id'=>$user1])->value('nickname');
'status' => 1, $text['user2_avatar'] = db::name('user')->where(['id'=>$user2])->value('avatar');
'type' => 1 $text['user2_nickname'] = db::name('user')->where(['id'=>$user2])->value('nickname');
]; model('api/Chat')->sendMsg(1051,$room_id,$text);
db::name('vs_room_cp_movie')->insert($datda); }
if($room_ids['data']){
$text['text'] = '交友结束并创建房间';
$text['relation_name'] = $relation;
$text['room_id'] = $room_ids['data'];//前端用来让用户跳转的房间id
$text['user1_id'] = $user1;//进小房间的用户id
$text['user2_id'] = $user2;//进小房间的用户id
$text['user1_avatar'] = db::name('user')->where(['id'=>$user1])->value('avatar');
$text['user1_nickname'] = db::name('user')->where(['id'=>$user1])->value('nickname');
$text['user2_avatar'] = db::name('user')->where(['id'=>$user2])->value('avatar');
$text['user2_nickname'] = db::name('user')->where(['id'=>$user2])->value('nickname');
model('api/Chat')->sendMsg(1051,$room_id,$text);
} }
}else{ }else{
$text['text'] = '交友结束未创建房间'; $text['text'] = '交友结束未创建房间';
@@ -227,7 +229,7 @@ class Friend extends Model
$text['step'] = 1;//1 等待邂逅 2 心动连线 3 牵手良缘 $text['step'] = 1;//1 等待邂逅 2 心动连线 3 牵手良缘
model('api/Chat')->sendMsg(1049,$room_id,$text); model('api/Chat')->sendMsg(1049,$room_id,$text);
db::commit(); db::commit();
return ['code' => 1, 'msg' => '创建关系成功', 'data' => null]; return ['code' => 1, 'msg' => '创建关系成功!'.$msg, 'data' => null];
} else { } else {
//推送给前端消息 //推送给前端消息
$text['text'] = '交友结束'; $text['text'] = '交友结束';

View File

@@ -278,7 +278,12 @@ class Ranking extends Model
} }
$lists = $guilds ; $lists = $guilds ;
$my_ranking = null; // $my_ranking = null;
$my_ranking['guild_name'] = '';
$my_ranking['cover'] = '';
$my_ranking['total'] = 0;
$my_ranking['rank'] = -1;
$my_ranking['diff'] = 0;
if($lists){ if($lists){
//获取当前用户的工会 //获取当前用户的工会
$myGuild = db::name('vs_guild_user')->where(['user_id' => UID])->find(); $myGuild = db::name('vs_guild_user')->where(['user_id' => UID])->find();

View File

@@ -591,14 +591,16 @@ class RoomPit extends Model
//有人就让他下麦 //有人就让他下麦
return ['code' => 0, 'msg' => '拍卖位上已有人,请先抱对方下麦', 'data' => null]; return ['code' => 0, 'msg' => '拍卖位上已有人,请先抱对方下麦', 'data' => null];
} }
$i = 0; // $i = 0;
foreach ($to_user as &$value) { // foreach ($to_user as &$value) {
$i++; // $i++;
$value = $to_user[0];
//删除他的申请上麦 //删除他的申请上麦
$reslut = db::name('vs_room_pit_apply')->where(['user_id' => $value, 'room_id' => $room_id, 'status' => 0])->delete(); $reslut = db::name('vs_room_pit_apply')->where(['user_id' => $value, 'room_id' => $room_id, 'status' => 0])->delete();
if (!$reslut) { // if (!$reslut) {
continue; // continue;
} // }
Cache::set('auction_user_'.$room_id,$value);
//聊天室推送系统消息 //聊天室推送系统消息
$FromUserInfo = db::name('user')->where('id',$value)->field('id as user_id,nickname,avatar,sex')->find(); $FromUserInfo = db::name('user')->where('id',$value)->field('id as user_id,nickname,avatar,sex')->find();
$FromUserInfo['icon'][0] = model('UserData')->user_wealth_icon($value);//财富图标 $FromUserInfo['icon'][0] = model('UserData')->user_wealth_icon($value);//财富图标
@@ -609,13 +611,13 @@ class RoomPit extends Model
$text['pit_number'] = 888; $text['pit_number'] = 888;
$text['type'] = 1 ; $text['type'] = 1 ;
model('Chat')->sendMsg(1022,$room_id,$text); model('Chat')->sendMsg(1022,$room_id,$text);
Cache::set('auction_user_'.$room_id,$value);
//1-禁麦位2-清空消息3-清空魅力值4-加入黑名单5-踢出房间6-关闭麦克风7-申请上麦8-同意上麦9-拒绝上麦10-点歌11-开启PK', //1-禁麦位2-清空消息3-清空魅力值4-加入黑名单5-踢出房间6-关闭麦克风7-申请上麦8-同意上麦9-拒绝上麦10-点歌11-开启PK',
model('Room')->room_operation_record($user_id,$room_id,8,$value); model('Room')->room_operation_record($user_id,$room_id,8,$value);
if($i >= 1){ // if($i >= 1){
break; // break;
} // }
} // }
$count = db::name('vs_room_pit_apply')->where(['room_id' => $room_id,'status' => 0])->count(); $count = db::name('vs_room_pit_apply')->where(['room_id' => $room_id,'status' => 0])->count();
//申请上麦推送消息 //申请上麦推送消息
$text = [ $text = [

View File

@@ -5,6 +5,7 @@
use think\Cache; use think\Cache;
use think\Db; use think\Db;
use think\exception\HttpResponseException; use think\exception\HttpResponseException;
use think\Log;
use think\Response; use think\Response;
if (!function_exists('__')) { if (!function_exists('__')) {
@@ -1102,7 +1103,9 @@ function handelCharge($where,$data){
function coin_earning($all_gift_price,$ratio){ function coin_earning($all_gift_price,$ratio){
//rmb_coin_ratio 人民币转换金币的比例 //rmb_coin_ratio 人民币转换金币的比例
//金币转换人民币 //金币转换人民币
return $all_gift_price * $ratio / 100 / get_system_config_value('rmb_coin_ratio'); //小数点保留4位
$result = $all_gift_price * $ratio / 100 / get_system_config_value('rmb_coin_ratio');
return round($result, 4);
} }
/** /**