diff --git a/application/api/controller/Cron.php b/application/api/controller/Cron.php index 147b7b9..0e9fa4b 100644 --- a/application/api/controller/Cron.php +++ b/application/api/controller/Cron.php @@ -37,4 +37,10 @@ class Cron $cron = new \app\cron\controller\RoomPan(); $cron->index(); } + + //交友房结束 + public function FriendEnd(){ + $cron = new \app\cron\controller\FriendEnd(); + $cron->index(); + } } \ No newline at end of file diff --git a/application/cron/controller/FriendEnd.php b/application/cron/controller/FriendEnd.php new file mode 100644 index 0000000..0e7b3c0 --- /dev/null +++ b/application/cron/controller/FriendEnd.php @@ -0,0 +1,56 @@ +clearFriendingEndRoom();//清除交友房过期未结束数据 + echo "清除结束 \n"; + + echo "清除私密小屋过期数据开始:\n"; + $this->clear_room_end();//清除私密小屋过期数据 + echo "清除私密小屋过期数据结束 \n"; + } + + + //清除交友房过期未结束数据 + public function clearFriendingEndRoom() + { + //清除交友房过期数据 + $room_list = db::name('vs_room')->where(['type_id'=>7])->whereIn('step', [2,3]) + ->field(['id','room_name','room_cover','step'])->select(); + if(!empty($room_list)){ + foreach ($room_list as $room) { + //查询交友信息 + $friending_info = db::name('vs_user_friending')->where('room_id', $room['id'])->where('status', 1)->order('id', 'desc')->find(); + if($friending_info){ + //判断结束时间是否到期 + if($friending_info['end_time'] <= time()){ + model('Friend')->end_friend(0,$room['id'],$friending_info['id'],1); + } + } + } + } + + } + + + //清除私密小屋过期数据 + public function clear_room_end() + { + $room_list = db::name('vs_room_cp_movie')->where(['type'=>1,'time_day' =>['<',time()]])->select(); + if(!empty($room_list)){ + foreach ($room_list as $room) { + model('Friend')->outRoom(0,$room['room_id']); + } + } + } +} \ No newline at end of file diff --git a/application/cron/controller/PerformPerSecond.php b/application/cron/controller/PerformPerSecond.php index e1d43d7..fb3b663 100644 --- a/application/cron/controller/PerformPerSecond.php +++ b/application/cron/controller/PerformPerSecond.php @@ -33,9 +33,9 @@ class PerformPerSecond // echo "提现云账号订单状态查询:\n"; // $this->withdraw_order_status(); // echo "\n"; - echo "清除交友房过期未结束数据:\n"; - $this->clearFriendingEndRoom(); - echo "\n"; +// echo "清除交友房过期未结束数据:\n"; +// $this->clearFriendingEndRoom(); +// echo "\n"; } @@ -166,34 +166,4 @@ class PerformPerSecond } } - - - //清除交友房过期未结束数据 - public function clearFriendingEndRoom() - { - //清除交友房过期数据 - $room_list = db::name('vs_room')->where(['type_id'=>7])->whereIn('step', [2,3]) - ->field(['id','room_name','room_cover','step'])->select(); - if(!empty($room_list)){ - foreach ($room_list as $room) { - //查询交友信息 - $friending_info = db::name('vs_user_friending')->where('room_id', $room['id'])->where('status', 1)->order('id', 'desc')->find(); - if($friending_info){ - //判断结束时间是否到期 - if($friending_info['end_time'] <= time()){ - model('Friend')->end_friend(0,$room['id'],$friending_info['id'],1); - } - } - } - } - //清除私密小屋过期数据 - $room_list = db::name('vs_room_cp_movie')->where(['type'=>1,'time_day' =>['<',time()]])->select(); - if(!empty($room_list)){ - foreach ($room_list as $room) { - model('Friend')->outRoom(0,$room['room_id']); - } - } - } - - } \ No newline at end of file