[游戏开发]将mysql数据表的数据转成百度ECharts可用的数据

数据表转换echarts数据格式录入数据库，方便查询使用。

表格: tp_table_analysis

备注: 表格分析 创建对某个表格进行分析的任务列表

索引:

字段:

表格: tp_table_statistic

备注: 通过分析表的任务生成的统计数据

索引:

字段:

数据: （例子数据生成）

 /**
     * 数据量不能过多，过多的时候需要考虑按照查询大表中数据的按照每年的数据进行分开查询数据写入，再不行就分月 分日 
     * 需要参数uuid
     * 1.获取分析数据的配置
     * 2.查询统计表table_statistic中是否存在已有的分析数据，获取最后的分析数据的最新【（年）数据、（年月）数据、（年月日）数据、（年月日时）、（年月日时分）】的数据各一条（这几个数据需要重新修改(因为有可能不是最新的了)）
     * 3.根据第1点和第2点得到数据--生成sql语句
     * 4.执行sql语句--查询
     * 5.将查询到数据封装成二维数组--
     * 6.写入到统计表中table_statistic
     */
    public function analyTable($analyUuid = ''){
        //第1步：根据uuid,获取分析数据的配置
        $analyData = $this->getDataByUUID();
        if($analyData['code'] !== 0){
            return $analyData;
        }

        if(empty($analyUuid)){
            $analyUuid = input('get.uuid');
        }

        // dump($analyData);

        //第2步：根据analy_uuid获取最新的数据
        $statisticData = $this->findByAnalyUUIDWithLastData(input('get.uuid'));
        if($statisticData['code'] !== 0){
            return $statisticData;
        }

        // dump($statisticData);

        //第3步：根据配置数据生成sql语句
        $sql = '';

        if($analyData['data']['table_analy_field_type'] == 1){
            $analyData['data']['table_analy_where'] = !empty($analyData['data']['table_analy_where'])?(($statisticData['data']['time_periods_int'] == 0)?$analyData['data']['table_analy_where']:$analyData['data']['table_analy_where']." and TO_DAYS(".$analyData['data']['table_analy_field'] . ") >= TO_DAYS('" .$statisticData['data']['time_periods']."')"):$analyData['data']['table_analy_where'];
            $sql = $sql."select UNIX_TIMESTAMP(".$analyData['data']['table_analy_field'].") as ".$analyData['data']['table_analy_field'].",".$analyData['data']['table_calculate_field']. " from ".$analyData['data']['table_name']." where ".$analyData['data']['table_analy_where'] ." order by ".$analyData['data']['table_analy_field'] ." asc";
        }else{
            $analyData['data']['table_analy_where'] = !empty($analyData['data']['table_analy_where'])?$analyData['data']['table_analy_where']." and ".$analyData['data']['table_analy_field'] . ">=" .$statisticData['data']['time_periods_int']:$analyData['data']['table_analy_where'];
            $sql = $sql."select ".$analyData['data']['table_analy_field'].",".$analyData['data']['table_calculate_field']. " from ".$analyData['data']['table_name']." where ".$analyData['data']['table_analy_where'] ." order by ".$analyData['data']['table_analy_field'] ." asc";
        }

        // dump($sql);

        // dump("第二步的数据需要拼至sql的where中，未完成");

        if(empty($sql)){
            return app('api_result')->returnArray(3,['msg'=>'sql语句不能为空！']);
        }
        //第4步：执行sql语句--如果数据过大- 下面的其他步骤就需要修改-- 解决方案是：将表进行拆分查询 然后再写入--比如将上面一步的查询数据修改为只查1万条数据即可，然后再重新进行分析
        // query方法用于执行SQL查询操作，如果数据非法或者查询错误则返回false，否则返回查询结果数据集（同select方法）。
        // Db::query("select * from think_user where status=1");
        // execute用于更新和写入数据的sql操作，如果数据非法或者查询错误则返回false，否则返回影响的记录数。
        // Db::execute("update think_user set name='thinkphp' where status=1");
        $dbData =  Db::query($sql);

        // dump($sql);

        if(empty($dbData)){
            return app('api_result')->returnArray(0,['msg'=>'执行sql语句，查询不到任何数据']);
        }
        // dump($dbData);
        // die;

        //第5步：封装数据
        //第一条数据为最开始的数据，最后一条数据为最新的数据
        $totalLength = count($dbData);
        $firstIndexData = $dbData[0];
        $lastIndexData = $dbData[count($dbData)-1];
        $firstYear = date("Y",$firstIndexData[$analyData['data']['table_analy_field']]);//最开始的年
        $firstMonth = date("m",$firstIndexData[$analyData['data']['table_analy_field']]);//最开始的月
        $firstDate = date("d",$firstIndexData[$analyData['data']['table_analy_field']]);//最开始的日
        $firstHour = date("H",$firstIndexData[$analyData['data']['table_analy_field']]);//最开始的小时
        $firstMinute = date("i",$firstIndexData[$analyData['data']['table_analy_field']]);//最开始的分钟
        $lastYear = date("Y",$lastIndexData[$analyData['data']['table_analy_field']]);//最后的年
        $lastMonth = date("m",$lastIndexData[$analyData['data']['table_analy_field']]);//最后的的月
        $lastDate = date("d",$lastIndexData[$analyData['data']['table_analy_field']]);//最后的的日
        $lastHour = date("H",$lastIndexData[$analyData['data']['table_analy_field']]);//最后的的小时
        $lastMinute = date("i",$lastIndexData[$analyData['data']['table_analy_field']]);//最后的的分钟

        // dump(date("Y-m-d h:i:s"),$firstIndexData);
        // dump(date("Y-m-d h:i:s"),$lastIndexData);
        // dump( $dbData);die;

        $data = []; //直接写入的数据
        $updateData = []; //直接更新的数据
        $backData = []; //需要重新计算的数据
        $startYear = $firstYear;
        //生成数据-从年-月-日-小时-分钟逐一开始
        for($y=$startYear; $y<=$lastYear;$y++){
           $yearNum = 0;//当前年数据
           for($j=0; $j<$totalLength; $j++){
                if(date("Y",$dbData[$j][$analyData['data']['table_analy_field']])==$y){
                    if($analyData['data']['table_calculate_method'] == 'count'){
                        $yearNum +=1;//加1
                    }
                    if($analyData['data']['table_calculate_method'] == 'sum'){
                        $yearNum += $dbData[$j][$analyData['data']['table_calculate_field']];//按照字段的值进行加
                    }
                }
           }
           //等于当前年的时候，需要写到更新数据中
           if($statisticData['data']['year'] == $y){
                //【分析类型-分析包含的数据】0 ：按照年，月，日，时，分；1：按照年，月，日，时；2：按照年，月，日；3：按照年，月；4：按照年
                if($analyData['data']['analy_type'] == 4){
                    //更新的数据需要重新查询  === 等于当前年时 只需要更新即可
                    $updateData = array_merge($updateData,[[
                        'analy_uuid'=>$analyUuid,
                        'time_periods'=>$y,
                        'count_num'=>$yearNum,
                        'time_type'=>'y',
                        'update_time'=>time()
                    ]]);
                }else{
                    //这个年份需要重新计算-- 正年的数据--- 包含历史数据和现在的数据 
                    //count_num == 按照分析任务的类型; 比如 年月 那么计算当前年的所有的月的总数据sum ; 年月日 则就算当前年的所有的日的总数据sum 其他的类比
                    $backData = array_merge($backData,[[
                        'analy_uuid'=>$analyUuid,
                        'time_periods'=>$y,
                        'count_num'=>0, // 需重算--- 
                        'update_time'=>time(),
                        'time_type'=>'y',
                        'analy_type'=>$analyData['data']['analy_type']
                    ]]);
                }
               
            }else{
                $data = array_merge($data,[[
                    'analy_uuid'=>$analyUuid,
                    'time_periods'=>$y,
                    'time_type'=>'y',
                    'count_num'=>$yearNum,
                    'create_time'=>time()
                ]]);
            }
           //analy_type的值有0，1，2，3，4 ---其中0是计算到分钟，1是计算到小时；2是计算到天，3是计算到月份，4计算到年
            if($analyData['data']['analy_type'] > 3){
                continue;
            }
           //月数据开始
           $startMonth = $y == $firstYear?$firstMonth:1;//最开始的一年，计算最开始的月份，其他的从1月份开始
           $lastMonthLength = $y == $lastYear?$lastMonth:12;//如果是最后一年，那么就计算到数据的最后一个月，其他的年份都是到12月
           for($m=$startMonth;$m<=$lastMonthLength;$m++){
                $monthNum = 0; //当前月数据
                for($j=0; $j<$totalLength; $j++){
                    if(date("Y/m",$dbData[$j][$analyData['data']['table_analy_field']]) == $y."/".sprintf('%02d',$m)){
                        if($analyData['data']['table_calculate_method'] == 'count'){
                            $monthNum +=1;//加1
                        }
                        if($analyData['data']['table_calculate_method'] == 'sum'){
                            $monthNum += $dbData[$j][$analyData['data']['table_calculate_field']];//按照字段的值进行加
                        }
                    }
                }
                //等于当前年当前月的时候，需要写到更新数据中
                if($statisticData['data']['year'] == $y && $statisticData['data']['month'] == sprintf('%02d',$m)){
                    //【分析类型-分析包含的数据】0 ：按照年，月，日，时，分；1：按照年，月，日，时；2：按照年，月，日；3：按照年，月；4：按照年
                    if($analyData['data']['analy_type'] == 3){
                        //更新的数据需要重新查询  === 等于当前年月时 只需要更新即可
                        $updateData = array_merge($updateData,[[
                            'analy_uuid'=>$analyUuid,
                            'time_periods'=>$y."/".sprintf('%02d',$m),
                            'count_num'=>$monthNum,
                            'time_type'=>'m',
                            'update_time'=>time()
                        ]]);
                    }else{
                        //这个年份需要重新计算-- 正年的数据--- 包含历史数据和现在的数据 
                        //count_num == 按照分析任务的类型; 比如 年月 那么计算当前年的所有的月的总数据sum ; 年月日 则就算当前年的所有的日的总数据sum 其他的类比
                        $backData = array_merge($backData,[[
                            'analy_uuid'=>$analyUuid,
                            'time_periods'=>$y."/".sprintf('%02d',$m),
                            'count_num'=>0,
                            'update_time'=>time(),
                            'time_type'=>'m',
                            'analy_type'=>$analyData['data']['analy_type']
                        ]]);
                    }

                }else{
                    $data = array_merge($data,[[
                        'analy_uuid'=>$analyUuid,
                        'time_periods'=>$y."/".sprintf('%02d',$m),
                        'time_type'=>'m',
                        'count_num'=>$monthNum,
                        'create_time'=>time()
                    ]]);
                }
                
                //analy_type的值有0，1，2，3，4 ---其中0是计算到分钟，1是计算到小时；2是计算到天，3是计算到月份，4计算到年
                if($analyData['data']['analy_type'] > 2){
                    continue;
                }
                //日数据开始
                $dateLength = cal_days_in_month(CAL_GREGORIAN, $m, $y);//计算当前月份中的天数
                // $dateLength = date('t', strtotime($m."-".$y));//计算当前月份中的天数 --- 如果没有装 

                $startDate = ($y == $firstYear && sprintf('%02d',$m) == $firstMonth)?$firstDate:1;//如果是最开始的一年的那个月，则计算最开始的一天的当天开始算
                $lastDateLength = ($y == $lastYear && sprintf('%02d',$m) == $lastMonth)?$lastDate:$dateLength;//如果是最后一年，那么就只计算到最后一天,否则就是当月的总天数
                for($d=$startDate;$d<=$lastDateLength;$d++){
                    $dateNum = 0;//当前日数据
                    for($j=0; $j<$totalLength; $j++){
                        if(date("Y/m/d",$dbData[$j][$analyData['data']['table_analy_field']]) == $y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d)){
                            if($analyData['data']['table_calculate_method'] == 'count'){
                                $dateNum +=1;//加1
                            }
                            if($analyData['data']['table_calculate_method'] == 'sum'){
                                $dateNum += $dbData[$j][$analyData['data']['table_calculate_field']];//按照字段的值进行加
                            }
                        }
                    }
                    //等于当前年当前月当前日的时候，需要写到更新数据中
                    if($statisticData['data']['year'] == $y && $statisticData['data']['month'] == sprintf('%02d',$m) && $statisticData['data']['date'] == sprintf('%02d',$d)){
                         //【分析类型-分析包含的数据】0 ：按照年，月，日，时，分；1：按照年，月，日，时；2：按照年，月，日；3：按照年，月；4：按照年
                        if($analyData['data']['analy_type'] == 2){
                            //更新的数据需要重新查询  === 等于当前年月时 只需要更新即可
                            $updateData = array_merge($updateData,[[
                                'analy_uuid'=>$analyUuid,
                                'time_periods'=>$y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d),
                                'count_num'=>$dateNum,
                                'time_type'=>'d',
                                'update_time'=>time()
                            ]]);
                        }else{
                            //这个年份需要重新计算-- 正年的数据--- 包含历史数据和现在的数据 
                            //count_num == 按照分析任务的类型; 比如 年月 那么计算当前年的所有的月的总数据sum ; 年月日 则就算当前年的所有的日的总数据sum 其他的类比
                            $backData = array_merge($backData,[[
                                'analy_uuid'=>$analyUuid,
                                'time_periods'=>$y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d),
                                'count_num'=>0,
                                'update_time'=>time(),
                                'time_type'=>'d',
                                'analy_type'=>$analyData['data']['analy_type']
                            ]]);
                        }
                    }else{
                        $data = array_merge($data,[[
                            'analy_uuid'=>$analyUuid,
                            'time_periods'=>$y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d),
                            'time_type'=>'d',
                            'count_num'=>$dateNum,
                            'create_time'=>time()
                        ]]);
                    }
                    //analy_type的值有0，1，2，3，4 ---其中0是计算到分钟，1是计算到小时；2是计算到天，3是计算到月份，4计算到年
                    if($analyData['data']['analy_type'] > 1){
                        continue;
                    }
                    //小时数据开始
                    $startHour = ($y == $firstYear && sprintf('%02d',$m) == $firstMonth && sprintf('%02d',$d) == $firstDate)?$firstHour:0;//如果是最开始的一年的那个月那一天，则计算最开始的一天的当天开始算
                    $lastHourLength = ($y == $lastYear && sprintf('%02d',$m) == $lastMonth && sprintf('%02d',$d) == $lastDate)?$lastHour:23;//如果是最后一年，那么就只计算到最后一天,否则就是当月的当天的当前小时
                    for($h=$startHour;$h<=$lastHourLength;$h++){
                        $hourNum = 0;//当前小时数据
                        for($j=0; $j<$totalLength; $j++){
                            if(date("Y/m/d H",$dbData[$j][$analyData['data']['table_analy_field']]) == $y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d)." ".sprintf('%02d',$h)){
                                if($analyData['data']['table_calculate_method'] == 'count'){
                                    $hourNum +=1;//加1
                                }
                                if($analyData['data']['table_calculate_method'] == 'sum'){
                                    $hourNum += $dbData[$j][$analyData['data']['table_calculate_field']];//按照字段的值进行加
                                }
                            }
                        }
                        //等于当前年当前月当前日当前小时的时候，需要写到更新数据中
                        if($statisticData['data']['year'] == $y && $statisticData['data']['month'] == sprintf('%02d',$m) && $statisticData['data']['date'] == sprintf('%02d',$d) && $statisticData['data']['hour'] == sprintf('%02d',$h)){
                             //【分析类型-分析包含的数据】0 ：按照年，月，日，时，分；1：按照年，月，日，时；2：按照年，月，日；3：按照年，月；4：按照年
                            if($analyData['data']['analy_type'] == 1){
                                //更新的数据需要重新查询  === 等于当前年月时 只需要更新即可
                                $updateData = array_merge($updateData,[[
                                    'analy_uuid'=>$analyUuid,
                                    'time_periods'=>$y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d)." ".sprintf('%02d',$h),
                                    'count_num'=>$hourNum,
                                    'time_type'=>'h',
                                    'update_time'=>time()
                                ]]);
                            }else{
                                //这个年份需要重新计算-- 正年的数据--- 包含历史数据和现在的数据 
                                //count_num == 按照分析任务的类型; 比如 年月 那么计算当前年的所有的月的总数据sum ; 年月日 则就算当前年的所有的日的总数据sum 其他的类比
                                $backData = array_merge($backData,[[
                                    'analy_uuid'=>$analyUuid,
                                    'time_periods'=>$y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d)." ".sprintf('%02d',$h),
                                    'count_num'=>$hourNum,
                                    'update_time'=>time(),
                                    'time_type'=>'h',
                                    'analy_type'=>$analyData['data']['analy_type']
                                ]]);
                            }

                        }else{
                            $data = array_merge($data,[[
                                'analy_uuid'=>$analyUuid,
                                'time_periods'=>$y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d)." ".sprintf('%02d',$h),
                                'time_type'=>'h',
                                'count_num'=>$hourNum,
                                'create_time'=>time()
                            ]]);
                        }    
                        //analy_type的值有0，1，2，3，4 ---其中0是计算到分钟，1是计算到小时；2是计算到天，3是计算到月份，4计算到年
                        if($analyData['data']['analy_type'] > 0){
                            continue;
                        }
                        //分钟数据开始
                        $startMinute = ($y == $firstYear && sprintf('%02d',$m) == $firstMonth && sprintf('%02d',$d) == $firstDate && sprintf('%02d',$h) == $firstHour)?$firstMinute:0;//如果是最开始的一年的那个月那一天那一小时，则计算最开始的一天的当天开始算
                        $lastMinuteLength = ($y == $lastYear && sprintf('%02d',$m) == $lastMonth && sprintf('%02d',$d) == $lastDate && sprintf('%02d',$h) == $lastHour)?$lastMinute:59;//如果是最后一年，那么就只计算到最后一天,否则就是当月的当天的当前小时
                        for($minute = $startMinute; $minute<=$lastMinuteLength;$minute++){
                            $minuteNum = 0;//当前小时数据
                            for($j=0; $j<$totalLength; $j++){
                                if(date("Y/m/d H",$dbData[$j][$analyData['data']['table_analy_field']]) == $y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d)." ".sprintf('%02d',$h).":".sprintf('%02d',$minute)){
                                    if($analyData['data']['table_calculate_method'] == 'count'){
                                        $minuteNum +=1;//加1
                                    }
                                    if($analyData['data']['table_calculate_method'] == 'sum'){
                                        $minuteNum += $dbData[$j][$analyData['data']['table_calculate_field']];//按照字段的值进行加
                                    }
                                }
                            }
                            //等于当前年当前月当前日当前小时的时候，需要写到更新数据中
                            if($statisticData['data']['year'] == $y && $statisticData['data']['month'] == sprintf('%02d',$m) && $statisticData['data']['date'] == sprintf('%02d',$d) && $statisticData['data']['hour'] == sprintf('%02d',$h) && $statisticData['data']['minute'] == sprintf('%02d',$minute)){
                             //【分析类型-分析包含的数据】0 ：按照年，月，日，时，分；1：按照年，月，日，时；2：按照年，月，日；3：按照年，月；4：按照年
                                
                                if($analyData['data']['analy_type'] == 0){
                                    //更新的数据需要重新查询  === 等于当前年月时 只需要更新即可
                                    $updateData = array_merge($updateData,[[
                                        'analy_uuid'=>$analyUuid,
                                        'time_periods'=>$y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d)." ".sprintf('%02d',$h).":".sprintf('%02d',$minute),
                                        'count_num'=>$minuteNum,
                                        'time_type'=>'i',
                                        'update_time'=>time()
                                    ]]);
                                }else{
                                    //这里应该没有作用  因为我的任务只计算到分钟 没有秒钟  但是保留代码
                                    //这个年份需要重新计算-- 正年的数据--- 包含历史数据和现在的数据 
                                    //count_num == 按照分析任务的类型; 比如 年月 那么计算当前年的所有的月的总数据sum ; 年月日 则就算当前年的所有的日的总数据sum 其他的类比
                                    // $backData = array_merge($backData,[[
                                    //     'analy_uuid'=>$analyUuid,
                                    //     'time_periods'=>$y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d)." ".sprintf('%02d',$h).":".sprintf('%02d',$minute),
                                    //     'count_num'=>0,
                                    //     'update_time'=>time(),
                                    //     'time_type'=>'i',
                                    //     'analy_type'=>$analyData['data']['analy_type']
                                    // ]]);
                                }
                            }else{
                                $data = array_merge($data,[[
                                    'analy_uuid'=>$analyUuid,
                                    'time_periods'=>$y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d)." ".sprintf('%02d',$h).":".sprintf('%02d',$minute),
                                    'time_type'=>'i',
                                    'count_num'=>$minuteNum,
                                    'create_time'=>time()
                                ]]);
                            }
                            
                        }//分钟-end      
                    }//小时-end
                }//天-end
            }//月-end
        }//年-end
      
        return $this->saveStatistic($data,$updateData,$backData,$analyUuid);

    }

    /**
     * 写入统计数据
     * @param $data 批量写入的数据
     * @param $updateData 批量要更新的数据 没有主键id
     * @param $backData 需要重新计算的数组
     * @param $analy_type 分析任务的类型
     */
    public function saveStatistic($data=[],$updateData=[],$backData = [],$analy_uuid=''){
        Db::startTrans();
        try {
            // dump($data);die;
            if(!empty($data)){
                // 分批写入 每次最多100条数据
                $list = Db::name('table_statistic')->limit(100)->insertAll($data);
            }
            
            //更新这一块数据 -- 只更新最后一条数据
            if(!empty($updateData)){
                for($i=0; $i<count($updateData); $i++){
                    Db::name('table_statistic') ->where([['analy_uuid','eq',$updateData[$i]['analy_uuid']],['time_periods','eq',$updateData[$i]['time_periods']]]) ->update($updateData[$i]);
                }
            }  
            $wheres = [];
            if(!empty($backData)){
                $wheres = $this->createBackDataWhere($backData);
                for($i=0; $i<count($backData); $i++){
                    $updateBackData = [
                        'analy_uuid'=>$backData[$i]['analy_uuid'],
                        'time_periods'=>$backData[$i]['time_periods'],
                        'time_type'=>$backData[$i]['time_type'],
                        'count_num'=>Db::name('table_statistic')->where($wheres[$i])->sum('count_num'),
                        'update_time'=>time()
                    ];
                    Db::name('table_statistic')
                        ->where([['analy_uuid','eq',$backData[$i]['analy_uuid']],['time_periods','eq',$backData[$i]['time_periods']]])
                        ->update($updateBackData);
                }
            }
            // 提交事务
            Db::commit();
            return app('api_result')->echoJson(0,['uuid'=>$analy_uuid,'msg'=>'任务成功']);
        } catch (\Exception $e) {
            // 回滚事务
            Db::rollback();
            return app('api_result')->echoJson(3,['uuid'=>$analy_uuid,'msg'=>'任务失败！']);
        }
       
    }

    /**
     * 返回 构造的查询条件
     */
    public function createBackDataWhere($backData){
        $wheres = [];
        for($i=0; $i<count($backData); $i++){
            $wheres[$i] = [];
            if(isset($backData[$i]['analy_type']) && isset($backData[$i]['time_type'])){
               //【分析类型-分析包含的数据】0 ：按照年，月，日，时，分；1：按照年，月，日，时；2：按照年，月，日；3：按照年，月；4：按照年
               switch ($backData[$i]['time_type']) {
                    case 'y':
                        switch ($backData[$i]['analy_type']) {
                            case 0:
                                $y = substr($backData[$i]['time_periods'],0,4);
                                for($m = 1; $m <= 12; $m++){
                                    $dateLength = cal_days_in_month(CAL_GREGORIAN, $m, $y);//计算当前月份中的天数
                                    for($d = 1; $d<= $dateLength; $d++){
                                        for($h = 0; $h< 24; $h++){
                                            for($minute = 0; $minute<60; $minute++){
                                                $wheres[$i] = array_merge($wheres[$i],[$y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d)." ".sprintf('%02d',$h).":".sprintf('%02d',$minute)]);
                                            }
                                        }
                                    }
                                }
                                break;
                            case 1:
                                $y = substr($backData[$i]['time_periods'],0,4);
                                for($m = 1; $m <= 12; $m++){
                                    $dateLength = cal_days_in_month(CAL_GREGORIAN, $m, $y);//计算当前月份中的天数
                                    for($d = 1; $d<= $dateLength; $d++){
                                        for($h = 0; $h< 24; $h++){
                                            $$wheres[$i] = array_merge($wheres[$i],[$y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d)." ".sprintf('%02d',$h)]);
                                        }
                                    }
                                }
                                break;
                            case 2:
                                $y = substr($backData[$i]['time_periods'],0,4);
                                for($m = 1; $m <= 12; $m++){
                                    $dateLength = cal_days_in_month(CAL_GREGORIAN, $m, $y);//计算当前月份中的天数
                                    for($d = 1; $d<= $dateLength; $d++){
                                        $wheres[$i] = array_merge($wheres[$i],[$y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d)]);
                                    }
                                }
                                break;
                            case 3:
                                $y = substr($backData[$i]['time_periods'],0,4);
                                for($m = 1; $m <= 12; $m++){
                                    $wheres[$i] = array_merge($wheres[$i],$y."/".sprintf('%02d',$m));
                                }
                                break;
                            case 4:
                                //年分析任务的话 此时不需要重算了 在上面的更新数据中,即statistic中的最后一条数据是使用更新 不需要重新计算
                                break;
                            default:
                                break;
                        }//end-switch
                        break;
                    case 'm':
                        switch ($backData[$i]['analy_type']) {
                            case 0:
                                $y = substr($backData[$i]['time_periods'],0,4);
                                $m = substr($backData[$i]['time_periods'],5,2);
                                $dateLength = cal_days_in_month(CAL_GREGORIAN, $m, $y);//计算当前月份中的天数
                                for($d = 1; $d<= $dateLength; $d++){
                                    for($h = 0; $h< 24; $h++){
                                        for($minute = 0; $minute<60; $minute++){
                                            $wheres[$i] = array_merge($wheres[$i],[$y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d)." ".sprintf('%02d',$h).":".sprintf('%02d',$minute)]);
                                        }
                                    }
                                }
                                break;
                            case 1:
                                $y = substr($backData[$i]['time_periods'],0,4);
                                $m = substr($backData[$i]['time_periods'],5,2);
                                $dateLength = cal_days_in_month(CAL_GREGORIAN, $m, $y);//计算当前月份中的天数
                                for($d = 1; $d<= $dateLength; $d++){
                                    for($h = 0; $h< 24; $h++){
                                        $wheres[$i] = array_merge($wheres[$i],[$y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d)." ".sprintf('%02d',$h)]);
                                    }
                                }
                                break;
                            case 2:
                                $y = substr($backData[$i]['time_periods'],0,4);
                                $m = substr($backData[$i]['time_periods'],5,2);
                                $dateLength = cal_days_in_month(CAL_GREGORIAN, $m, $y);//计算当前月份中的天数
                                for($d = 1; $d<= $dateLength; $d++){
                                    $wheres[$i] = array_merge($wheres[$i],[$y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d)]);
                                }
                                break;
                            case 3:
                                //月分析任务的话 此时不需要重算了 在上面的更新数据中,即statistic中的最后一条数据是使用更新 不需要重新计算
                                break;
                            case 4:
                                //年分析任务的话 此时不需要重算了 在上面的更新数据中,即statistic中的最后一条数据是使用更新 不需要重新计算
                                break;
                            default:
                                break;
                        }//end-switch  
                    break;
                    case "d":
                        switch ($backData[$i]['analy_type']) {
                            case 0:
                                $y = substr($backData[$i]['time_periods'],0,4);
                                $m = substr($backData[$i]['time_periods'],5,2);
                                $d = substr($backData[$i]['time_periods'],8,2);
                                for($h = 0; $h< 24; $h++){
                                    for($minute = 0; $minute<60; $minute++){
                                        $wheres[$i] = array_merge($wheres[$i],[$y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d)." ".sprintf('%02d',$h).":".sprintf('%02d',$minute)]);
                                    }
                                }
                                break;
                            case 1:
                                $y = substr($backData[$i]['time_periods'],0,4);
                                $m = substr($backData[$i]['time_periods'],5,2);
                                $d = substr($backData[$i]['time_periods'],8,2);
                                for($h = 0; $h< 24; $h++){
                                    $wheres[$i] = array_merge($wheres[$i],[$y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d)." ".sprintf('%02d',$h)]);
                                }
                                break;
                            case 2:
                               //日分析任务的话 此时不需要重算了 在上面的更新数据中,即statistic中的最后一条数据是使用更新 不需要重新计算
                                break;
                            case 3:
                                //月分析任务的话 此时不需要重算了 在上面的更新数据中,即statistic中的最后一条数据是使用更新 不需要重新计算
                                break;
                            case 4:
                                //年分析任务的话 此时不需要重算了 在上面的更新数据中,即statistic中的最后一条数据是使用更新 不需要重新计算
                                break;
                            default:
                                break;
                        }//end-switch 
                        break;
                        case "h":
                            switch ($backData[$i]['analy_type']) {
                                case 0:
                                    $y = substr($backData[$i]['time_periods'],0,4);
                                    $m = substr($backData[$i]['time_periods'],5,2);
                                    $d = substr($backData[$i]['time_periods'],8,2);
                                    $h = substr($backData[$i]['time_periods'],11,2);
                                    for($minute = 0; $minute<60; $minute++){
                                        $wheres[$i] = array_merge($wheres[$i],[$y."/".sprintf('%02d',$m)."/".sprintf('%02d',$d)." ".sprintf('%02d',$h).":".sprintf('%02d',$minute)]);
                                    }
                                    break;
                                case 1:
                                    //时分析任务的话 此时不需要重算了 在上面的更新数据中,即statistic中的最后一条数据是使用更新 不需要重新计算
                                    break;
                                case 2:
                                   //日分析任务的话 此时不需要重算了 在上面的更新数据中,即statistic中的最后一条数据是使用更新 不需要重新计算
                                    break;
                                case 3:
                                    //月分析任务的话 此时不需要重算了 在上面的更新数据中,即statistic中的最后一条数据是使用更新 不需要重新计算
                                    break;
                                case 4:
                                    //年分析任务的话 此时不需要重算了 在上面的更新数据中,即statistic中的最后一条数据是使用更新 不需要重新计算
                                    break;
                                default:
                                    break;
                            }//end-switch 
                            break;
                    default:
                        # code...
                        break;

                }//end-switch 
                $where = [['analy_uuid','eq',$backData[$i]['analy_uuid']]];  
                $wheres[$i] = !empty($wheres[$i])?array($where,[['time_periods','in',$wheres[$i]]]):$where;
            }//end-if
        }//end-for
        return $wheres;
    }

测试图：这里分析了最近12个月的数据，由于只有一个月的数据，其他月份数据为0，所以柱状图比较大 。