123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391 |
- <?php
- namespace app\index\controller;
- use app\utils\JingXiu\JingXiuPayUtil;
- use think\Controller;
- use think\Db;
- use think\Cache;
- class Plantask extends Controller
- {
- /**
- * 精秀支付订单支付状态查询
- * @return string|void
- */
- public function auto_pay_queue()
- {
- // 处理次数
- $queue_times = 6;
- //查询订单信息 十分钟未处理的
- $order_info = Db::name('pay_order')
- ->where('queue_status', 1)
- ->where('status',0)
- ->where('queue_times','<',$queue_times)
- ->where('createtime','<',time() - 600)
- ->order('queue_times','asc')
- ->find();
- if (!$order_info){
- return '无订单';
- }
- // 增加处理次数
- Db::name('pay_order')->where('id',$order_info['id'])->update(['queue_times' => $order_info['queue_times'] + 1]);
- // 查询订单是否支付成功
- $pay = new JingXiuPayUtil();
- if (!$pay->getOrder($order_info['pay_no'])){
- $this->error($pay->getMessage());
- }
- //PROCESSING=订单待支付,SUCCESS=订单支付成功,TIME_OUT=订单已过期,FAIL=订单支付失败,CLOSE=订单关闭,CALL_FAIL=支付成功未返回
- $params = $pay->getData();
- if (empty($params['order_status']) || $params['order_status'] != 'SUCCESS' || empty($params['out_trade_no'])) {
- $status = $params['order_status'] ?? 'error';
- return '支付信息有误'.$status.':'.$params['out_trade_no'];
- }
- // 开始处理业务逻辑
- $pay_no = $params['out_trade_no'];
- //查询订单信息
- $order_info = Db::name('pay_order')->where('pay_no', $pay_no)->find();
- if (!$order_info) {
- return '订单信息不存在'.$pay_no;
- }
- if ($order_info['status'] == 3){
- return '订单信息_已删除'.$pay_no;
- }
- if ($order_info['status'] == 1 || $order_info['status'] == 2) {
- return '充值入账更新余额失败_status已更新过'.$pay_no;
- }
- $extendType = '';
- //区分vip 还是 冲金币
- $is_g = stripos($pay_no, 'P');
- if ($is_g !== false) {
- $extendType = 'gold';
- } else {
- $is_v = stripos($pay_no, 'V');
- if ($is_v !== false) {
- $extendType = 'vip';
- }
- }
- //status已更新过
- $result = Db::name('pay_order')->where('pay_no', $pay_no)->where('status',$order_info['status'])->setField(['status' => 2]);
- if (!$result) {
- return '充值入账更新余额失败_status更新状态2不成功'.$pay_no;
- }
- //你可以在此编写订单逻辑
- $payEvent = Db::name('pay_event')->where('pay_no', $pay_no)->find();
- $args = json_decode($payEvent['args'] ?? '', true);
- $rechargeM = new \app\common\model\Recharge();
- if ($extendType == 'gold') {
- $payRes = $rechargeM->goldpaysucc($pay_no, $args);
- $payTypeStr = '充值';
- } elseif ($extendType == 'vip') {
- $payRes = $rechargeM->vippaysucc($pay_no, $args);
- $payTypeStr = 'vip';
- } else {
- $payRes = false;
- $payTypeStr = '未知支付类型';
- }
- if (!$payRes) {
- return '更新失败'.$payTypeStr.$pay_no;
- }
- return '订单处理成功'.$payTypeStr.$pay_no;
- }
- //定时跑用户活跃,改成离线
- public function auto_user_active(){
- $actitime = time() - 7200;
- $sql = 'update `mt_user` set is_active = 0 where is_active = 1 and id in (select user_id from mt_user_active where requesttime < '.$actitime.')';
- db()->query($sql);
- }
- //计划任务
- //代替公会的人10秒内发出五句话
- public function firstuser_send()
- {
- exit;
- //找出24小时内注册的男人
- $map = [
- 'jointime' => ['gt',time()-86400],
- 'gender' => 1,
- 'gh_id' => 0,
- 'auto_first_word' => 0,
- ];
- $oneuser = Db::name('user')->where($map)->order('id asc')->value('id');
- dump($oneuser);
- if(!$oneuser){
- echo 'empty';
- exit;
- }
- //找出公会的人
- $map = [
- 'gh_id' => ['gt',0],
- 'gender' => 0,
- ];
- $ghuser = Db::name('user')->where($map)->orderRaw('rand()')->limit(5)->column('id');
- //dump($ghuser);
- //随机取出一句话
- $oneword = Db::name('plantask_accost')->orderRaw('rand()')->limit(5)->column('title');
- //dump($oneword);
- //发送出去
- $tenim = new \app\common\library\Tenim;
- for($i = 0;$i < 5;$i++){
- $ghuser_one = isset($ghuser[$i]) ? $ghuser[$i] : $ghuser[array_rand($ghuser)];
- $oneword_one = isset($oneword[$i]) ? $oneword[$i] : $oneword[array_rand($oneword)];
- $tenim->sendMessageToUser($ghuser_one,$oneuser,$oneword_one);
- sleep(2);
- }
- Db::name('user')->where('id',$oneuser)->update(['auto_first_word'=>1]);
- }
- //计划任务,二期之后,废弃
- //代替公会的人发出第一句话
- public function firstword_send()
- {
- exit;
- //找出24小时内注册的男人
- $map = [
- 'jointime' => ['gt',time()-86400],
- 'gender' => 1,
- 'gh_id' => 0,
- ];
- $oneuser = Db::name('user')->where($map)->orderRaw('rand()')->value('id');
- //dump($oneuser);
- //找出公会的人
- $map = [
- 'gh_id' => ['gt',0],
- 'gender' => 0,
- ];
- $ghuser = Db::name('user')->where($map)->orderRaw('rand()')->value('id');
- //dump($ghuser);
- //随机取出一句话
- $oneword = Db::name('plantask_accost')->orderRaw('rand()')->value('title');
- //dump($oneword);
- //发送出去
- $cache = Cache::connect(['type'=>'Redis']);
- $times = $cache->get('plantask_first_word_'.$oneuser);
- //dump($times);
- if($times === false){
- $times = 0;
- }
- if($times < 5){
- $tenim = new \app\common\library\Tenim;
- $tenim->sendMessageToUser($ghuser,$oneuser,$oneword);
- $cache->set('plantask_first_word_'.$oneuser, $times + 1);
- }
- }
- //计划任务
- //清空没用的redis
- public function firstword_clear(){
- $map = [
- 'jointime' => ['between',[time()-172800,time()-86400]],
- 'gender' => 1,
- 'gh_id' => 0,
- ];
- $map = [];
- $userlist = Db::name('user')->where($map)->order('id asc')->column('id');
- if(empty($userlist)){
- echo 'empty';
- exit;
- }
- //清除
- $cache = Cache::connect(['type'=>'Redis']);
- foreach($userlist as $key => $val){
- $cache->rm('plantask_first_word_'.$val);
- }
- }
- //测试用
- //清空redis
- public function clear_redis(){
- $val = input('uid');
- $cache = Cache::connect(['type'=>'Redis']);
- $cache->rm('plantask_first_word_'.$val);
- }
- //发放代理奖励
- public function issuingreward() {
- set_time_limit(0);
- //本周开始时间
- $week_start_time = strtotime(date('Y-m-d')) - ((date('w')==0?7:date('w'))-1)*86400;
- $where['user_id'] = ['gt', 0];
- $where['issuingtime'] = ['elt', $week_start_time];
- $mt_admin = Db::name('admin');
- $list = $mt_admin->field('id, user_id, issuingtime')->where($where)->limit(100)->select();
- if (!$list) {
- echo 'mei shu ju';
- die;
- }
- //上周开始时间 上周结束时间
- $starttime = $week_start_time - 604800;
- $endtime = $week_start_time - 1;
- $money_map['log_type'] = ['in', [21, 22, 23, 54, 60, 82]];
- $money_map['createtime'] = ['between', [$starttime, $endtime]];
- $mt_user_money_log = Db::name('user_money_log');
- $mt_user = Db::name('user');
- $mt_extend_reward = Db::name('extend_reward');
- $issuingtime = time();
- foreach ($list as $k => &$v) {
- //开启事务
- Db::startTrans();
- //修改记录状态
- $rs = $mt_admin->where(['id' => $v['id'], 'issuingtime' => $v['issuingtime']])->setField('issuingtime', $issuingtime);
- if (!$rs) {
- Db::rollback();
- continue;
- }
- $user_ids = $mt_user->where(['intro_uid' => $v['user_id']])->column('id');
- if ($user_ids) {
- $money_map['user_id'] = ['in', $user_ids];
- //周收益
- $week_sum_money = $mt_user_money_log->where($money_map)->sum('change_value');
- $week_sum_money = $week_sum_money > 0 ? $week_sum_money : 0;
- if ($week_sum_money) {
- //查询推广奖励等级
- $extend_reward_info = $mt_extend_reward->where(['total_flow' => ['elt', $week_sum_money]])->order('id desc')->find();
- if ($extend_reward_info) {
- //额外提成
- $extra_moeny = number_format($week_sum_money * $extend_reward_info['extra_reward'] / 100, 2, '.', '');
- if ($extra_moeny > 0) {
- //发放额外提出
- $wallet_rs = model('wallet')->lockChangeAccountRemain($v['user_id'],0,'money',$extra_moeny,91,'额外提成奖励');
- if($wallet_rs['status'] === false){
- Db::rollback();
- } else {
- //发送系统消息
- \app\common\model\Message::addMessage($v['user_id'],'额外提成奖励','上周额外提成奖励已经发放');
- }
- }
- }
- }
- }
- Db::commit();
- }
- echo 'wan bi';
- die;
- }
- /**
- * 超过24小时未上传头像的女用户隐身
- * @return void
- */
- public function userHide()
- {
- //找出24小时内注册未上传头像的女用户
- $userHideTime = config('site.user_hide_time');
-
- $start_time = time() - (3600 * 27);
- $end_time = time() - ($userHideTime * 60);
-
- $girlAvatar = config('avatar_girl');
- $where = [
- 'gender' => 0,
- 'avatar' => $girlAvatar,
- 'status' => 1,
- ];
-
- $user = Db::name('user')->field('id')->whereBetween('jointime',[$start_time,$end_time])->where($where)->order('id asc')->select();
- if(empty($user)){
- echo 'empty';
- exit;
- }
- $userIds = array_column($user,'id');
- $updateWhere['id'] = ['in',$userIds];
- $countRes = Db::name('user')->where($updateWhere)->update(['status'=>2]);//隐藏
- echo 'update '.$countRes;
- exit;
- }
-
- /**
- * 五分钟禁用女用户账号
- * @return void
- */
- public function userClose()
- {
- $start_time = time() - (3600 * 27);
- $end_time = time() - (5 * 60);
- $where = [
- 'gender' => 0,
- 'is_closed' => 0,
- 'status' => 1,
- ];
- $user = Db::name('user')->field('id')->whereBetween('jointime',[$start_time,$end_time])->where($where)->order('id asc')->select();
- if(empty($user)){
- echo 'empty';
- exit;
- }
- $userIds = array_column($user,'id');
- $updateWhere['id'] = ['in',$userIds];
- $updateWhere2['user_id'] = ['in',$userIds];
- $countRes = Db::name('user')->where($updateWhere)->update(['status'=>0,'is_closed'=>1]);//金庸
- $countRes2 = Db::name('user_token')->where($updateWhere2)->delete();//金庸
- echo 'update '.$countRes;
- echo 'delete '.$countRes2;
- exit;
- }
- /**
- * 自动推荐
- * @return void
- */
- public function userRecommend()
- {
- $payMoney = config('site.recommend_pay_money');//财富值
- $getMoney = config('site.recommend_get_money');//魅力值
- if ($payMoney <= 0 && $getMoney <= 0) {
- echo 'empty';exit;
- }
- $where = 'u.is_recommend = 0 ';
- if ($payMoney > 0) {
- $whereAppend = $where.' and uw.pay_money >= '.$payMoney;
- }
- if ($getMoney > 0) {
- $whereAppend = $where.' and uw.get_money >= '.$getMoney;
- }
- if ($payMoney >0 && $getMoney >0) {
- $whereAppend = $where. ' and (uw.pay_money >= '.$payMoney.' or uw.get_money >= '.$getMoney.')' ;
- }
- $user = Db::name('user')->alias('u')->field('u.id')
- ->join('user_wallet uw','uw.user_id = u.id','LEFT')
- ->where($whereAppend)
- ->select();
- if (empty($user)) {
- echo 'update 0';exit;
- }
- $userIds = array_column($user,'id');
- $userWhere['id'] = ['in',$userIds];
- $userUpdateData['is_recommend'] = 1;
- $userUpdateData['updatetime'] = time();
- $userRes = Db::name('user')->where($userWhere)->update($userUpdateData);
- echo 'update '.$userRes;exit;
- }
- }
|