<?php
/**
+-----------------------------------------------------------------------------------------------------------------------
 * 控制层：数据统计控制类
+----------------------------------------------------------------------------------------------------------------------
 *
 * PHP version 7
 *
 * @category  App\Http\Controllers\Web
 * @package   App\Http\Controllers\Web
 * @author    Richer <yangzi1028@163.com>
 * @date      2021年9月18日16:27:06
 * @copyright 2021-2022 Richer (http://www.Richer.com/)
 * @license   http://www.Richer.com/ License
 * @link      http://www.Richer.com/
 */
namespace App\Http\Controllers\Web;

use App\Models\Area\Building;
use App\Models\Area\Room;
use App\Models\Area\Village;
use App\Models\Lock\Lock;
use App\Models\Smoke\Smoke;
use App\Models\User\Tenant;
use App\Models\User\UserRoom;
use App\Models\Warning;
use Carbon\Carbon;
use Illuminate\Http\JsonResponse;
use Illuminate\Support\Arr;
use Illuminate\Support\Collection;
use Illuminate\Routing\Controller;
use Illuminate\Support\Facades\DB;

/**
 * Class StatisticsController
 *
 * @category  App\Http\Controllers\Web
 * @package   App\Http\Controllers\Web
 * @author    Richer <yangzi1028@163.com>
 * @date      2021年9月18日16:27:06
 * @copyright 2021-2022 Richer (http://www.Richer.com/)
 * @license   http://www.Richer.com/ License
 * @link      http://www.Richer.com/
 */
class StatisticsController extends Controller
{

    /**
     * 进入页面
     *
     * @return array|string
     * @throws \Throwable
     */
    public function index()
    {
        // 获取全部的社区
        $villages = Village::where('status', config('constants.STATUS_OK'))->get();
        return view(
            'web.home',
            [
                'villages'              => $villages,
            ]
        )->render();
    }
    /**
     * @return JsonResponse
     */
    public function count()
    {
        // 累计销售额
        $data['total_smoke'] = $this->getCount('smoke');
        $data['total_smoke_abnormal'] = $this->getCount('smoke', 'abnormal');
        $data['total_lock']  = $this->getCount('lock');
        $data['total_lock_abnormal']  = $this->getCount('lock', 'abnormal');
        return response()->json($data);
    }

    /**
     * 获取数量
     *
     * @param $module
     * @param string $type
     * @param int $village_id
     * @param int $building_id
     * @return mixed
     */
    public function getCount($module, $type = '', $village_id = 0, $building_id = 0)
    {
        $query = null;
        switch ($module) {
            case 'smoke':
                $query = app(Smoke::class);
                break;
            case 'lock':
                $query = app(Lock::class);
                break;
        }

        if ($type === 'abnormal') {
            $query = $query->where('status', '<>', 1);
        }

        if ($village_id) {
            $query = $query->where('village_id', $village_id);
        }

        if ($building_id) {
            $query = $query->where('building_id', $building_id);
        }

        return $query->count();
    }

    /**
     * 获取最近一周的设备报警数控
     */
    public function smokeWarnings()
    {
        $data = $this->getChartData('smoke-warnings', 'bar');
        return response()->json($data);
    }

    /**
     * 各区新入用户
     */
    public function newTenant()
    {
        $data = $this->getChartData('new-tenant', 'line');
        return response()->json($data);
    }

    /**
     * 各区新入用户
     */
    public function alarms()
    {
        $data = $this->getChartData('alarms', 'pie');
        return response()->json($data);
    }

    /**
     * 各区异常智慧烟感
     */
    public function smokeAbnormal()
    {
        $data = $this->getChartData('smoke-abnormal', 'line');
        return response()->json($data);
    }

    /**
     * 各区异常智慧烟感
     */
    public function lockAbnormal()
    {
        $data = $this->getChartData('lock-abnormal', 'pie');
        return response()->json($data);
    }

    /**
     * 小镇入驻概况
     */
    public function rooms()
    {
        $data = $this->getChartData('rooms', 'bar-2');
        return response()->json($data);
    }

    /**
     * 根据查询条件获取数据，并渲染到地图上面
     *
     * @return JsonResponse
     */
    public function getMapData()
    {
        // 获取楼栋的信息
        $village    = request('village');
        $group      = request('group');
//        $building   = request('building');
        $query = Building::where('status', config('constants.STATUS_OK'));
//        $query = Area::where('level', Area::LEVEL_BUILDING);

        if ($village) {
            $query->where('village_id', $village);
//            $query->where('path', 'like', ','.$village.',%');
        }
        if ($group) {
            $query->where('group_id', $group);
//            $query->where('path', 'like', '%,'.$group.',%');
        }
        $building = $query->get(['id','village_id','group_id','title','latitude','longitude','address']);
//        $building = $query->get(['id','title','longitude','latitude','level','path']);
        return response()->json(
            [
                'status'  => 1,
                'msg'  => 'success',
                'data' => $building->toArray(),
            ]
        );
    }
/**
     * 根据查询条件获取数据，并渲染到地图上面
     *
     * @return JsonResponse
     */
    public function getBuildingData()
    {
        $building_id = request('id');
        // 累计销售额
        $data['smoke_count'] = $this->getCount('smoke', '', 0, $building_id);
        $data['smoke_abnormal_count'] = $this->getCount('smoke', 'abnormal', 0, $building_id);
        $data['lock_count']  = $this->getCount('lock', '', 0, $building_id);
        $data['lock_abnormal_count']  = $this->getCount('lock', 'abnormal', 0, $building_id);
        return response()->json($data);
    }

    /**
     * 获取数据：获取数据并转成echart图表的数据格式
     *
     * @param $type
     * @param string $chartType 图表类型
     *
     * @return array
     */
    public function getChartData($type, $chartType = 'line')
    {
        $results        = $this->getBysql($type, $chartType);
        if ($type === 'lock-abnormal') {
            return [
                'count'         => $results['count'] ,
                'count_abnormal'  => $results['count_abnormal'],
                'ratio'       => $results['ratio'],
                'seriesData'  => $results['data'],
            ];
        }
        // 获取图表的名称
        $chartName      = $this->getChartName($type);
        // 获取图表的名称
        $yAxisName      = $this->getyAxisName($type);
        // 获取新坐标的数据
        $return     = [];
        $legendData = [];  // legend 数据
        $seriess    = []; //
        $xAxisData  = []; // x轴数据集
        $seriesData  = []; //
        switch ($chartType) {
            case 'pie_inner':
                $legendData     = $results['legends'];
                $seriesData[0]['name'] = '客户端类型';
                $seriesData[0]['data'] = $results['client'];
                $seriesData[1]['name'] = '访问模块';
                $seriesData[1]['data'] = $results['modules'];
                $pie_data1      = $results['client'];
                $pie_data2      = $results['modules'];
                break;
            case 'pie':
                $legendData     = $results['legends'];
                $seriesData     = $results['data'];
//                $seriesData[0]['name'] = '客户端类型';
//                $seriesData[0]['data'] = $results['client'];
//                $seriesData[1]['name'] = '访问模块';
//                $seriesData[1]['data'] = $results['modules'];
//                $pie_data1      = $results['client'];
//                $pie_data2      = $results['modules'];
                break;
            case 'bar-2':
                $chartType = 'bar';
                $legendData     = $results['legends'];
                $xAxisData      = $results['xAxisData'];
                $seriess        = $results['data'];
//                $seriesData[0]['name'] = '客户端类型';
//                $seriesData[0]['data'] = $results['client'];
//                $seriesData[1]['name'] = '访问模块';
//                $seriesData[1]['data'] = $results['modules'];
//                $pie_data1      = $results['client'];
//                $pie_data2      = $results['modules'];
                break;
            default:
                // 默认为折线图
                $xAxisData      = Arr::get($results, 'days');
                $seriesData     = Arr::get($results, 'values');

                $series['name']             = $chartName;
                $legendData[]               = $chartName;
                $series['type']             = $chartType;
                $series['barWidth']             = 10;
                $series['smooth']           = true;// 折线显示为平滑的曲线
                // 设置数据
                $series['data']             = Arr::get($results, 'values');
                $series['symbolSize']       = 8;//拐点大小

                // 标签 样式
                $label['show']           =  false; // 是否显示
                //$label_normal['color']      = '#01B4F4'; // 颜色
                $label['position']       = '#top'; // 位置
                $textStyle['align']      = 'right';// 水平对齐方式，可选为：'left' | 'right' | 'center'
                $textStyle['baseline']   = 'top';// 垂直对齐方式，可选为：'top' | 'bottom' | 'middle'
                $textStyle['fontSize']   = '14';// 字号 ，单位px
                $textStyle['fontStyle']  = 'italic';// 样式，可选为：'normal' | 'italic' | 'oblique'
                $textStyle['fontWeight'] = '900';// 粗细，可选为：'normal' | 'bold' | 'bolder' | 'lighter' | 100 | 200 |... | 900
                $label['textStyle']      = $textStyle;
                $series['itemStyle']['normal']['label']    = $label;

//                // 折线样式设置
//                $lineStyle['width'] = 1;
//                $lineStyle['shadowColor']   = 'rgba(0,0,0,0)';
//                $lineStyle['shadowBlur']    = 5;
//                $lineStyle['shadowOffsetX'] = 3;
//                $lineStyle['shadowOffsetY'] = 3;
//                $series['itemStyle']['normal']['lineStyle']    = $lineStyle;
//                //  显示一个区域
//                $areaStyle['type'] = 'default';//
//                $areaStyle['color'] = '#D5EFFE';

               // $series['itemStyle']['normal']['areaStyle']    = $areaStyle;
                $seriess[] = $series;

                break;
        }
        $symbolColor = '#0956ff';
        return [
            'xAxisData'       => $xAxisData ,
            'series'          => $seriess,
            'chartName'       => $chartName,
            'yAxisName'       => $yAxisName,
            'legendData'      => $legendData,
            'chartType'       => $chartType,
            'seriesData'      => $seriesData,
            'symbolColor'     => $symbolColor,
        ];
    }

    /**
     * 获取查询结果集
     * 1、获取用户角色，
     * 2、组合查询的SQL语句
     *
     * @param string $type 类型
     * @param string $chartType
     * @return mixed
     */
    public function getBysql($type, $chartType = 'line')
    {
        // 结束时间
        $end_date   = Carbon::tomorrow();
        $start_date = Carbon::parse($end_date)-> subDays(7);
        switch ($type) {
            case 'smoke-warnings':// 最近7天
            case 'new-tenant':// 最近7天
            case 'smoke-abnormal':// 最近7天
//            case 'alarms':// 最近7天
                $start_date = Carbon::parse($end_date)->subDays(7);
                break;
            case 'week':
                // 本周第一天
                $start_date = now()->startOfWeek();
                break;
            case 'month':
                // 这个月第一天
                $start_date = now()->firstOfMonth();
                break;
            case 'timerange':// 根据时间范围来查询
                $d1 = request()-> get('startdate');
                if (!$d1) {
                    $d1 = '2019-01-01';
                }
                $start_date   = Carbon::parse($d1);

                $d2 = request()-> get('enddate');
                if (!$d2) {
                    $end_date = Carbon::tomorrow();
                } else {
                    $end_date     = Carbon::parse($d2)-> addDays(1);
                }
                break;
            default:
                //
                break;
        }

        // 计算时间差
        $diff     = $end_date->diffInDays($start_date);

        // 获取时间范围
        $start_date = $start_date->toDateString();
        $end_date   = $end_date->toDateString();
        $dates[]    = $start_date;
        for ($i=1; $i<=$diff-1; $i++) {
            $dates[]    = date('Y-m-d', strtotime("$start_date +$i days"));
        }

        $list = new Collection();
        // 根据类型查询
        switch ($type) {
            case 'smoke-warnings':// 烟感报警设备
                $list = Warning::select(
                    array(
                        \DB::raw('COUNT(*) as count'),
                        \DB::raw('DATE_FORMAT(created_at, "%Y-%m-%d") AS day')
                    )
                )->whereDate('created_at', '>=', $start_date)
                ->whereDate('created_at', '<', $end_date)
                ->groupBy('day')->get();
                break;
            case 'new-tenant':// 各区新入用户
                $village_id = request('village_id', 1);
                $list = Tenant::select(
                    array(
                        \DB::raw('COUNT(id) as count'),
                        \DB::raw('DATE_FORMAT(created_at, "%Y-%m-%d") AS day')
                    )
                )->whereDate('created_at', '>=', $start_date)
                ->whereDate('created_at', '<', $end_date)
                ->where('village_id', $village_id)
                ->groupBy('day')->get();
                break;
            case 'smoke-abnormal':// 各区异常智慧烟感
                $village_id = request('village_id', 1);
                $list = Warning::select(
                    array(
                        \DB::raw('COUNT(id) as count'),
                        \DB::raw('DATE_FORMAT(created_at, "%Y-%m-%d") AS day')
                    )
                )->whereDate('created_at', '>=', $start_date)
                ->whereDate('created_at', '<', $end_date)
                ->where('village_id', $village_id)
                ->where('status', 0)
                ->groupBy('day')->get();
                break;
            case 'alarms':// 烟感累计报警器
                $legends = [];
                $values = [];
                $list = Warning::with(['village'])->select(
                    array(
                        \DB::raw('COUNT(id) as count'),
                        \DB::raw('village_id')
                    )
                )->groupBy('village_id')->get()->map(function ($item) use (&$legends, &$values) {
                    $legends[] = $item->village->title;
                    $values[] = $item->count;
                    return [
                        'name' =>  $item->village->title,
                        'value' =>  $item->count,
                    ];
                })->toArray();
                $return['legends']  = $legends;
                $return['values']   = $values;
                $return['data']     = $list;
                return $return;
            case 'lock-abnormal':// 智能门锁故障统计
                $legends = [];
                $values = [];
                $village_id = request('village_id', 1);
                $query = Lock::with(['village'])->select(
                    array(
                        \DB::raw('COUNT(id) as count'),
                        \DB::raw('village_id')
                    )
                )->where('village_id', $village_id);
                $count          = $query->count();
                $countAbnormal  = $query->where('status', config('constants.STATUS_NO'))->count();
                $seriesData = [
                    [
                        'value' => $count,
                        'name' => '该区域智能锁设备故障重量',
                    ],
                    [
                        'value' => $countAbnormal,
                        'name' => '该区域智能锁设备总量',
                    ],
                ];
                $return['legends']  = $legends;
                $return['values']   = $values;
                $return['data']     = $seriesData;
                $return['count']     = $count;
                $return['count_abnormal']  = $countAbnormal;
                if ($count > 0) {
                    $return['ratio']  = 100 * ($countAbnormal / $count);
                } else {
                    $return['ratio']  = 0;
                }
                return $return;
            case 'rooms':// 烟感累计报警器
//                $legendData     = $results['legends'];
//                $xAxisData      = $results['xAxisData'];
//                $seriess        = $results['data'];
                $return['legends']  = ['出租', '总户数'];
                $xAxisData = [];
                $dataTenantRooms = [];
                $dataRooms = [];
//                $tenantRooms = UserRoom::with(['village'])->select(
//                    array(
//                        DB::raw('COUNT(id) as count'),
//                        DB::raw('village_id')
//                    )
//                )->where('roomable_type', 'tenant')->groupBy('village_id')->get();
                $rooms = Room::with(['village'])->select(
                    array(
                        DB::raw('COUNT(id) as count'),
                        DB::raw('village_id')
                    )
                )->groupBy('village_id')->get()->map(function ($item) use (&$xAxisData, &$dataTenantRooms, &$dataRooms) {
                    $xAxisData[] = $item->village->title;
                    $dataRooms[] = $item->count;
                    $dataTenantRooms[] = UserRoom::where('roomable_type', 'tenant')->where('village_id', $item->village_id)->count();
                    return [
                        'name' =>  $item->village->title,
                        'value' =>  $item->count,
                    ];
                })->toArray();

                $data[] = [
                    'name' => '出租',
                    'type' => 'bar',
                    'data' => $dataTenantRooms,
                    'stack' => 'x',
                ];
                $data[] = [
                    'name' => '总户数',
                    'type' => 'bar',
                    'data' => $dataRooms,
                    'stack' => 'x',
                ];
                $return['xAxisData']     = $xAxisData;
                $return['data']     = $data;
                return $return;
                break;
        }

        $values = [];
        $days = [] ;
        if (request('test') == 1) {
            dump($list->toArray());
        }
        foreach ($dates as $key => $value) {
            $item = $list->where('day', $value)->first();
            $count = $item ? $item->count : 0;
            if (request('test') == 1) {
                dump($item);
                dump($count);
            }
            $data['day']    = $value;
            $data['count']  = $count;
            $values[]    = $count;
            $days[]      = substr($value, 5);
        }
        if (request('test') == 1) {
            dump($list->toArray());
        }
        $return['days']     = $days;
        $return['values']   = $values;


        return $return;

        $return = [];
        switch ($chartType) {
            case 'pie':
                $legends = [];
                $values = [];
                $rs = $list->map(function ($item) use (&$legends, &$values) {
                    $legends[] = $item->village->title;
                    $values[] = $item->count;
                    return [
                        'name' =>  $item->village->title,
                        'value' =>  $item->count,
                    ];
                })->toArray();
                $return['legends']     = $legends;
                $return['values']   = $values;
                $return['data']   = $rs;
//                dd($return);
//                if ($rs) {
//                    foreach ($rs as $vo) {
//                        $return['days']     = $days;
//                        $return['values']   = $values;
//                    }
//                }

                break;
            default:
                $values = [];
                $days = [] ;
                foreach ($dates as $key => $value) {
                    $item = $list->where('day', $value)->first();
                    $count = $item ? $item->count() : 0;
                    $data['day']    = $value;
                    $data['count']  = $count;
                    $values[]    = $count;
                    $days[]      = substr($value, 5);
                }

                $return['days']     = $days;
                $return['values']   = $values;
                break;
        }



        return  $return;
    }

    /**
     * 获取echart图表的显示名称
     *
     * @param $type
     * @param string $sort 排序方式
     *
     * @return string
     */
    public function getChartName($type, $sort = '')
    {
        switch ($type) {
            case 'smoke-warnings':// 最近7天
                return '最近7天火警情况';
            case 'alarms':// 烟感累计报警器
                return '烟感累计报警器';
            default:
                //
                break;
        }
    }

    /**
     * 获取echart图表的显示名称
     *
     * @param $type
     * @return string
     */
    public function getyAxisName($type)
    {
        switch ($type) {
            case 'smoke-warnings':// 最近7天
                return '(次)';
            case 'new-tenant'://
                return '(人)';
            case 'rooms'://
                return '(户)';
            default:
                //
                break;
        }
    }
}