替换实时查组id

module/Pass/Pass.php

@@ -53,4 +53,52 @@ class Pass
         $groupIdArr = array_column($groupRes,'groupId') ?: [];
         return $dataType == 2 ? $groupIdArr : implode(",",$groupIdArr);
     }
+
+    /**
+     * 获取实时统计组id
+     * @param $config
+     * @param $token
+     * @param $dataType
+     * @return array|string
+     */
+    public static function getRealGroupIds($config,$token,$dataType)
+    {
+        $url = $config['host_url'] . "/api/cfas/v2/countGroup/groups/page";
+        $pageNo = 1;
+        $pageSize = 1;
+
+        $groupIdArr = [];
+        while (1) {
+
+            $dataArr = [
+                "regionId"=> "root000000",
+                "isCascade"=> 1,
+                "groupType"=> 0,
+                "statType"=> 0,
+                "pageNo"=> $pageNo,
+                "pageSize"=> $pageSize
+            ];
+
+            $json_data = json_encode($dataArr);
+            $result = post_token($url,$json_data,false,[],$token);
+            $res_data = json_decode($result,true);
+
+            # 存在错误结束循环
+            if ($res_data['code'] != 0) break;
+            # 数据不存在结束循环
+            $list = (array)$res_data['data']['list'];
+            if (empty($list)) break;
+
+            foreach ($list as $value) {
+
+                $groupIdArr[] = $value['groupId'];
+            }
+
+            # 总条数不够结束循环
+            if (count($list) < $pageSize) break;
+            ++$pageNo;
+        }
+
+        return $dataType == 2 ? $groupIdArr : implode(",",$groupIdArr);
+    }
 }

tasks/Pass.php

@@ -33,7 +33,7 @@ class Pass
 
         $requestData = [];
         try {
-            $ids = \task\module\Pass\Pass::getGroupIds(1);
+            $ids = \task\module\Pass\Pass::getRealGroupIds($config,$token,1);
             foreach ($arr as $granularity => $value) {
 
                 $dataArr = [

tasks/Passall.php

@@ -43,7 +43,7 @@ class Passall
         $requestData = [];
 
         try {
-            $ids = Pass::getGroupIds(1);
+            $ids = Pass::getRealGroupIds($config,$token,1);
 
             foreach ($dateArr as $date => $value) {
 

tasks/Passreal.php

@@ -19,9 +19,9 @@ class Passreal
         try{
 
             $url = $config['host_url'] . "/api/cfas/v3/passenger/realTime";
-            $dataArr = Pass::getGroupIds(2);
 
             $token = get_access_token();
+            $dataArr = Pass::getRealGroupIds($config,$token,2);
             $json_data = json_encode($dataArr);
             $result = post_token($url,$json_data,false,[],$token);