<?php

namespace task\tasks;


include 'Base.php';
class Passall extends Base
{
    public function run()
    {
        $config = $this->config('api_config');
        $dateData = $this->get_target_date();
        $token = $this->get_access_token();

        $dateArr = [
            'day' => [
                'startTime' => $dateData['day']['c_start_time'],// 当天开始时间
                'endTime' => date("c"),// 当天结束时间
                'granularity' => 'daily'
            ],
            'week' => [
                'startTime' => $dateData['week']['c_start_time'],
                'endTime' => date("c"),
                'granularity' => 'daily'
            ],
            'month' =>[
                'startTime' => $dateData['month']['c_start_time'],
                'endTime' => date("c"),
                'granularity' => 'monthly'
            ],
            'year' =>[
                'startTime' => date("c",strtotime("-10 year")),
                'endTime' => date("c",time()),
                'granularity' => 'yearly'
            ]

        ];

        $requestData = [];

        try {
            $ids = $this->get_real_group_ids($config,$token,1);

            foreach ($dateArr as $date => $value) {

                $url = $config['host_url'] . "/api/cfas/v2/passengerFlow/groups";
                $granularity = $value['granularity'];

                $dataArr = [
                    'granularity' => $granularity,
                    'startTime' => $value['startTime'],
                    'endTime' => $value['endTime'],
                    'ids' => $ids
                ];

                $json_data = json_encode($dataArr);
                $result = $this->post_token($url,$json_data,false,[],$token);

                $res_data = json_decode($result,true);
                if ($res_data['code'] != 0) throw new \Exception('请求失败');
                $list = (array)$res_data['data']['list'];
                foreach ($list as $val) {
                    $insert_arr = [
                        'groupId'           => $val['groupId'],
                        'groupName'         => $val['groupName'],
                        'flowInNum'         => $val['flowInNum'] ?: 0,
                        'flowOutNum'        => $val['flowOutNum'] ?: 0,
                        'noRepeatInNum'     => $val['noRepeatInNum'] ?: 0,
                        'noRepeatOutNum'    => $val['noRepeatOutNum'] ?: 0,
                        'holdValue'         => $val['holdValue'] ?: 0,
                        'createTime'        => $val['createTime'],
                        'updateTime'        => $val['updateTime'],
                        'netValue'          => $val['netValue'] ?: 0,
                        'statTime'          => $val['statTime'],
                        'granularity'       => $granularity,
                        'date'              => $date,
                    ];

                    $requestData[] = $insert_arr;
                }
            }

        } catch (\Exception $e) {
            return $e->getMessage();
        }

        $requestRes = $this->request_create_data($requestData,'/api/pass.create/createPassengerFlowAll', $config['host_path']);

        if (!$requestRes['status']) {
            return $requestRes['msg'];
        }

        return true;
    }
}
$Passall = new Passall();
echo $Passall->run();
$Passall = new Passall();
echo $Passall->run();