Sjzs_admin/application/api/controller/Timedtask.php

<?php


namespace app\api\controller;
use think\Db;
use think\Exception;

/**
 * @title 定时任务
 * Class Timedtask
 * @controller Timedtask
 */
class Timedtask
{

    /**
     * @title 每天早上
     * @desc  每天7-16点，没10秒造一次假数据
     * @author  Gavin
     * @url /index.php/api/Timedtask/SetFakeDate
     * @method GET
     */
    public function SetFakeDate(){
        $day = 3;
        $date_array = Db::name('system_values')
            ->group('date')
            ->order('date desc')
            ->limit($day)
            ->column('date');

        $kd = Db::name('system_kd')->select();
        foreach ($kd as &$v){
            if (in_array($v['name'],['中通','申通'])){
                $va = Db::name('system_values2')
                    ->whereIn('date',$date_array)
                    ->where('name',$v['name'])
                    ->sum('value') ? : 0;
                if ($va>0){
                    $v['value'] = ceil(bcdiv($va,$day));
                }
            }else{
                $va1 = Db::name('system_values')
                    ->whereIn('date',$date_array)
                    ->where('name',$v['name'])
                    ->sum('value') ? : 0;
                if ($va1>0){
                    $va1 = ceil(bcdiv($va1,$day));
                }
                $va2 = Db::name('system_values2')
                    ->whereIn('date',$date_array)
                    ->where('name',$v['name'])
                    ->sum('value') ? : 0;
                if ($va2>0){
                    $va2 = ceil(bcdiv($va2,$day));
                }
                $v['value'] = ceil(bcadd($va1,$va2));
            }
        }
        $all = array_sum(array_column($kd,'value'));
        $date = date('Y-m-d');
        $info = Db::name('system_day')->where('date',$date)->count();
        if (!$info){
            Db::name('system_day')->insertGetId(
                [
                    'date'=>$date,
                    'all_value'=>$all,
                    'now_value'=>$all
                ]
            );

            foreach ($kd as &$v){
                Db::name('system_day_fake')->insert(
                    [
                        'name'=>$v['name'],
                        'date'=>$date,
                        'rate'=>$v['value']
                    ]
                );
            }
        }
    }

    /**
     * @title 一个小时获取一次天气
     * @desc  一个小时获取一次天气
     * @author  Gavin
     * @url /index.php/api/Timedtask/GetWeather
     * @method GET
     */
    public function GetWeather(){
        $info = Db::name('system_day')->where('date',date('Y-m-d'))->find();
        if ($info){
            //使用聚合天气api
            $url = "http://apis.juhe.cn/simpleWeather/query?city=富平&key=1f7300e5c17ba2e584c9a1cd39553148";
            $result = file_get_contents($url);
            if ($result){
                $weather = json_decode($result,true);
                if ($weather['error_code']==0){
                    $this_day_weather = $weather['result']['future'][0]['weather'];
                    Db::name('system_day')->where('id',$info['id'])->update(['weather_json'=>$result,'weather'=>$this_day_weather]);
                }
            }
        }
    }



    /**
     * @title 每天7-10点，14-16:30,没5秒造一次假数据
     * @desc  每天7-10点，14-16:30,没5秒造一次假数据
     * @author  Gavin
     * @url /index.php/api/Timedtask/SetFake
     * @method GET
     */
    public function SetFake(){
        $now_hour = date('H');
        $min = date('i');
        if (($now_hour>=7 && $now_hour<10) || ($now_hour>=14 && $now_hour<17)){
            if ($now_hour==16 && $min>30){
                die();
            }
            $all = Db::name('system_day')->where('date',date('Y-m-d'))->value('all_value');
            $now_time = date('Y-m-d 07:00:00');
            $end_time = date('Y-m-d 10:00:00');
            $now_time1 = date('Y-m-d 14:00:00');
            $end_time1 = date('Y-m-d 16:30:00');
            $strto = (strtotime($end_time)-strtotime($now_time))+(strtotime($end_time1)-strtotime($now_time1));
            $num = ceil($all/($strto/5));
            $num_array =array();
            for ($i=$num-2;$i<=$num+2;$i++){
                if ($i>0){
                    array_push($num_array,$i);
                }
            }

            $kd = Db::name('system_day_fake')
                ->where('rate','gt',0)
                ->where('date',date('Y-m-d'))
                ->field('id,name,rate')
                ->select();
            foreach ($kd as $key => $val) {
                $arr[$val['id']] = $val['rate'];//概率数组
            }
            $rid = get_rand($arr); //根据概率获取id

            $value = $num_array[array_rand($num_array)];

            Db::startTrans();
            Db::name('system_day_fake')->where('id',$rid)->setInc('value',$value);
            Db::name('system_day')->where('date',date('Y-m-d'))->setDec('now_value',$value);
            Db::name('system_day_fake')->where('id',$rid)->setDec('rate',$value);
            Db::commit();
//            file_put_contents("timelog.txt", $value. "\n" . "\n", FILE_APPEND);
        }
    }


    /**
     * @title 每天7-16点，没5秒造一次假数据
     * @desc  每天7-16点，没5秒造一次假数据
     * @author  Gavin
     * @url /index.php/api/Timedtask/SetFake
     * @method GET
     */
    public function SetFake2(){
        $now_hour = date('H');
        $min = date('i');
        if (($now_hour>7 && $now_hour<10) || ($now_hour>14 && $now_hour<17)){
            if ($now_hour==16 && $min>30){
                die();
            }
            $all = Db::name('system_day')->where('date',date('Y-m-d'))->value('now_value');
            if ($all>0){
                $now_time = date('Y-m-d 07:00:00');
                $end_time = date('Y-m-d 10:00:00');
                $now_time1 = date('Y-m-d 14:00:00');
                $end_time1 = date('Y-m-d 16:30:00');
                $strto = (strtotime($end_time)-strtotime($now_time))+(strtotime($end_time1)-strtotime($now_time1));
                $num = ceil($all/($strto/5));
                echo $num;die;
                $num_array =array();
                for ($i=$num-2;$i<=$num+2;$i++){
                    if ($i>0){
                        array_push($num_array,$i);
                    }
                }

                $kd = Db::name('system_day_fake')
                    ->where('rate','gt',0)
                    ->where('date',date('Y-m-d'))
                    ->field('id,name,rate')
                    ->select();
                foreach ($kd as $key => $val) {
                    $arr[$val['id']] = $val['rate'];//概率数组
                }
                $rid = get_rand($arr); //根据概率获取id

                $value = $num_array[array_rand($num_array)];

                Db::startTrans();
                Db::name('system_day_fake')->where('id',$rid)->setInc('value',$value);
                Db::name('system_day')->where('date',date('Y-m-d'))->setDec('now_value',$value);
                Db::name('system_day_fake')->where('id',$rid)->setDec('rate',$value);
                Db::commit();
            }
        }
    }

}