setName('passengerFlow') ->addArgument('name', Argument::OPTIONAL, "your name") ->addOption('city', null, Option::VALUE_REQUIRED, 'city name') ->setDescription('Say Hello'); } protected function execute(Input $input, Output $output) { $config = config('app'); $dateData = getTargetDate(); $token = getAccessToken(); $arr = [ 'hourly' => [ 'startTime' => $dateData['day']['c_start_time'], 'endTime' => $dateData['day']['c_end_time'], ], 'daily' => [ 'startTime' => $dateData['month']['c_start_time'], 'endTime' => $dateData['month']['c_end_time'], ], 'monthly' => [ 'startTime' => $dateData['year']['c_start_time'], 'endTime' => date('c'), ] ]; $url = $config['host_url'] . "/api/cfas/v2/passengerFlow/groups"; $delete = Db::table('tp_passenger_flow')->where('id','>',1)->delete(); try { foreach ($arr as $granularity => $value) { $dataArr = [ 'granularity' => $granularity, 'startTime' => $value['startTime'], 'endTime' => $value['endTime'], 'ids' => '01' // --- --- // ]; $json_data = json_encode($dataArr); $result = postToken($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'], 'flowOutNum' => $val['flowOutNum'], 'noRepeatInNum' => $val['noRepeatInNum'], 'noRepeatOutNum' => $val['noRepeatOutNum'], 'holdValue' => $val['holdValue'], 'createTime' => $val['createTime'], 'updateTime' => $val['updateTime'], 'netValue' => $val['netValue'], 'statTime' => $val['statTime'], 'granularity' => $granularity, ]; Db::table('tp_passenger_flow')->insert($insert_arr); } } $output->writeln('完成'); } catch (\Exception $e) { $output->writeln($e->getMessage()); } } } //return $res_data['data']['list'];