gaoyixia/application/api/controller/Task.php

<?php
namespace app\api\controller;

use app\common\model\ActivityApply;
use app\common\model\ActivityApplyItem;
use app\common\model\ActivityPrice;
use app\common\model\ArticleItem;
use app\common\model\DatumUrl;
use app\common\model\LabelMessage;
use app\common\model\TopSearch;
use app\common\model\User;
use app\common\model\UserFacility;
use app\common\model\UserMessage;
use app\common\model\UserSearch;
use app\common\model\VideoUrl;
use app\common\service\UserSynth;
use think\Db;

/**
 * @title 定时任务
 * Class Task
 * @controller Task
 * @group base
 */
class Task extends Base
{
    /**
     * @title 标签推送[根据标签id]
     * @desc  标签推送
     * @author  qc
     * @url /api/Task/taskUserMessage
     */
    public function taskUserMessage(){
        $list = UserMessage::field('id,user_id,content')->where('jg_type',1)->where('jg_status',0)->limit(0,50)->order('id')->select();
        foreach ($list as $v) {
            UserMessage::where(['id'=>$v['id']])->update(['jg_status'=>1]);
            UserMessage::Jpush($v['user_id'],$v['content']);
        }
    }


    /**
     * @title 标签推送[根据标签id]
     * @desc  标签推送
     * @author  qc
     * @url /api/Task/taskLabelMessage
     */
    //按照标签推送
    public function taskLabelMessage()
    {
        $list = LabelMessage::where('jg_status',0)->where('is_deleted',0)->select()->toArray();
        foreach ($list as $v) {
            LabelMessage::where(['id'=>$v['id']])->update(['jg_status'=>1]);
            // 全部推送
            if(!$v['label']) {
                $user_arr = User::where('status',1)->where('is_deleted',0)->column('id');
                foreach ($user_arr as $user_id) {
                    if($v['type'] == 2){
                        $res =  UserMessage::Jpush($user_id,$v['content']);
                    }else if($v['type'] == 3) {
                        if(in_array($v['module'],['video','article','datum'])) {
                            $res =  UserMessage::Jpush($user_id,$v['content'],$v['module'],'',$v['first_id'],$v['second_id']);
                        }else{
                            $res =  UserMessage::Jpush($user_id,$v['content'],$v['module'],'',$v['first_id']);
                        }
                    }
                }
            }else{
                // 搜索内容推送
                $label_arr = explode(',',$v['label']);
                $where_str = '';
                $search_arr=[];
                foreach ($label_arr as $t){
                    $search_arr[] =  " title like '".'%'.$t."%'" .' ';
                }
                if(!empty($search_arr)) $where_str  =  implode(' OR ',$search_arr);
                $user_arr = UserSearch::where($where_str)->column('user_id');
                foreach (array_unique($user_arr) as $user_id) {
                    if($v['type'] == 2){
                        $res =  UserMessage::Jpush($user_id,$v['content']);
                    }else if($v['type'] == 3) {
                        if(in_array($v['module'],['video','article','datum'])) {
                            $res =  UserMessage::Jpush($user_id,$v['content'],$v['module'],'',$v['first_id'],$v['second_id']);
                        }else{
                            $res =  UserMessage::Jpush($user_id,$v['content'],$v['module'],'',$v['first_id']);
                        }
                    }
                }
            }

        }
    }

    /**
     * @title 半年清理一次设备号
     * @desc
     * @author  qc
     * @url /api/Task/removeFacility
     */
    public function removeFacility(){
        UserFacility::where(['set_time','< time',date('Y-m-d H:i:s',strtotime('-180 days'))])->update(['facility'=>'','set_time'=>date('Y-m-d H:i:s')]);
    }


    /**
     * @title 定时取消活动订单
     * @desc
     * @author  qc
     * @url /api/Task/cancelApplyOrder
     */
    public function cancelApplyOrder()
    {
        $list = ActivityApply::with(['itemList'])
            ->where([['create_at','< time',date('Y-m-d H:i:s',strtotime('-5 minutes'))],['pay_type','<>',9],['pay_state','=',0],['cancel_state','=',0]])
            ->select()->toArray();
        foreach ($list as $v) {
            Db::startTrans();
            try {
                ActivityApply::where('id',$v['id'])->update(['cancel_state'=>1]);
                $act_title = \app\common\model\Activity::where('id',$v['act_id'])->value('title');
                $info_url =  'https://'.$_SERVER['HTTP_HOST'].'/dist/#/activity_order_info?id='.$v['id'];
                $message = '您报名的《'.$act_title."》活动订单，由于超时未支付，已为您取消";//,点击<a href=\"$info_url\">查看详情</a>";
                UserMessage::sendUserMessage($v['user_id'],'activity',4,0,0,$v['id'],$message,$v['id']);
                foreach ($v['item_list'] as $it) {
                    ActivityPrice::where('id',$it['price_id'])->setInc('stock',$it['num']);
                }
                Db::commit();
            }catch (\Exception $e) {
                Db::rollback();
            }
        }
    }


    /**
     * @title 活动报名定时提醒
     * @desc
     * @author  qc
     * @url /api/Task/activityReminder
     */
    public function activityReminder()
    {
        $where = [];
        $where[] = ['task_send','=',0];
        $where[] = ['start_time','> time',date('Y-m-d H:i:s',strtotime('-24 hours'))];
        $where[] = ['status','=',1];
        $where[] = ['is_deleted','=',0];
        $list = \app\common\model\Activity::where($where)->select()->toArray();
        foreach ($list  as $act_info)
        {
            \app\common\model\Activity::where(['id'=>$act_info['id']])->update(['task_send'=>1]);
            $ticket_list =  ActivityApplyItem::where(['act_id'=>$act_info['id'],'sh_status'=>1,'is_hx'=>0])->select();
            foreach ($ticket_list as $v) {
                // 短信通知
                if($v['phone_pre'] == '86' && $v['phone']) UserSynth::phoneMessageSend($v['phone'],0,['ActivityName'=>$act_info['title'], 'time'=>$act_info['start_time'], 'adress'=>$act_info['address']]);
            }
        }

    }


    /**
     * @title 热搜定时
     * @desc
     * @author  qc
     * @url /api/Task/topSearchTask
     */
    public function topSearchTask()
    {
        $where[] = ['hot_time','< time',date('Y-m-d H:i:s',strtotime('-7 days'))];
        // 视频
        $list = VideoUrl::where($where)->column('id');
        array_walk($list,function ($v){
            VideoUrl::where('id',$v)->update(['hot_time'=>date('Y-m-d H:i:s'),'hot_num'=>0]);
            TopSearch::saveData($v,'video');
        });
        // 图文
        $list = ArticleItem::where($where)->column('id');
        array_walk($list,function ($v){
            ArticleItem::where('id',$v)->update(['hot_time'=>date('Y-m-d H:i:s'),'hot_num'=>0]);
            TopSearch::saveData($v,'article');
        });
        // 资料
        $list = DatumUrl::where($where)->column('id');
        array_walk($list,function ($v){
            DatumUrl::where('id',$v)->update(['hot_time'=>date('Y-m-d H:i:s'),'hot_num'=>0]);
            TopSearch::saveData($v,'datum');
        });
        // 活动
        $list = \app\common\model\Activity::where($where)->column('id');
        array_walk($list,function ($v){
            \app\common\model\Activity::where('id',$v)->update(['hot_time'=>date('Y-m-d H:i:s'),'hot_num'=>0]);
            TopSearch::saveData($v,'activity');
        });


        // 需求
        $list = \app\common\model\PlatformDemand::where($where)->column('id');
        array_walk($list,function ($v){
            \app\common\model\PlatformDemand::where('id',$v)->update(['hot_time'=>date('Y-m-d H:i:s'),'hot_num'=>0]);
            TopSearch::saveData($v,'demand');
        });

        // 新闻
        $list = \app\common\model\Press::where($where)->column('id');
        array_walk($list,function ($v){
            \app\common\model\Press::where('id',$v)->update(['hot_time'=>date('Y-m-d H:i:s'),'hot_num'=>0]);
            TopSearch::saveData($v,'press');
        });

        // 问答
        $list = \app\common\model\UserForum::where($where)->column('id');
        array_walk($list,function ($v){
            \app\common\model\UserForum::where('id',$v)->update(['hot_time'=>date('Y-m-d H:i:s'),'hot_num'=>0]);
            TopSearch::saveData($v,'forum');
        });
        // 招聘
        $list = \app\common\model\Recruit::where($where)->column('id');
        array_walk($list,function ($v){
            \app\common\model\Recruit::where('id',$v)->update(['hot_time'=>date('Y-m-d H:i:s'),'hot_num'=>0]);
            TopSearch::saveData($v,'recruit');
        });

        // 供应商
        $list = \app\common\model\SupplierGoods::where($where)->column('id');
        array_walk($list,function ($v){
            \app\common\model\SupplierGoods::where('id',$v)->update(['hot_time'=>date('Y-m-d H:i:s'),'hot_num'=>0]);
            TopSearch::saveData($v,'supplier_goods');
        });

        // 商品
        $list = \app\common\model\StoreGoods::where($where)->column('id');
        array_walk($list,function ($v){
            \app\common\model\StoreGoods::where('id',$v)->update(['hot_time'=>date('Y-m-d H:i:s'),'hot_num'=>0]);
            TopSearch::saveData($v,'goods');
        });

        $this->success('执行成功');

    }





}