替换组id为接口返回组id

source/application/common/model/Pass.php

@@ -2,6 +2,8 @@
 
 namespace app\common\model;
 
+use app\common\dm\Dm;
+
 class Pass extends BaseModel
 {
     public static $unit = [1 => '>', 2 => '<', 3 => '=', 4 => '≥', 5 => '<=', 6 => '!='];
@@ -65,4 +67,17 @@ class Pass extends BaseModel
         if ($result['code'] != 1) return ['status' => 0, 'msg' => $result['msg']];
         return ['status' => 1];
     }
+
+    /**
+     * 获取统计组ID
+     * @param $dataType     // 1 返回字符串 2 返回数组
+     * @return array|string
+     */
+    public static function getGroupIds($dataType)
+    {
+        $dm = new Dm();
+        $groupRes = $dm->select('bt_passenger_monitor_group',null,'"groupId"');
+        $groupIdArr = array_column($groupRes,'groupId') ?: [];
+        return $dataType == 2 ? $groupIdArr : implode(",",$groupIdArr);
+    }
 }

source/application/task/controller/Pass.php

@@ -40,13 +40,14 @@ class Pass
 
         $requestData = [];
         try {
+            $ids = \app\common\model\Pass::getGroupIds(1);
             foreach ($arr as $granularity => $value) {
 
                 $dataArr = [
                     'granularity' => $granularity,
                     'startTime' => $value['startTime'],
                     'endTime' => $value['endTime'],
-                    'ids' => '01' // --- <replace> --- //
+                    'ids' => $ids
                 ];
 
                 $json_data = json_encode($dataArr);

source/application/task/controller/Passall.php

@@ -46,6 +46,7 @@ class Passall
         $requestData = [];
 
         try {
+            $ids = \app\common\model\Pass::getGroupIds(1);
 
             foreach ($dateArr as $date => $value) {
 
@@ -56,7 +57,7 @@ class Passall
                     'granularity' => $granularity,
                     'startTime' => $value['startTime'],
                     'endTime' => $value['endTime'],
-                    'ids' => '01' // --- <replace> --- //
+                    'ids' => $ids
                 ];
 
                 $json_data = json_encode($dataArr);

source/application/task/controller/Passreal.php

@@ -22,9 +22,7 @@ class Passreal
         try{
 
             $url = $config['host_url'] . "/api/cfas/v3/passenger/realTime";
-            $dataArr = [
-                '01' // --- <replace> --- //
-            ];
+            $dataArr = \app\common\model\Pass::getGroupIds(2);
 
             $token = getAccessToken();
             $json_data = json_encode($dataArr);