优化各场管实施实时进馆人数增加拥挤度

source/application/task/controller/Group.php

@@ -0,0 +1,83 @@
+<?php
+
+namespace app\task\controller;
+
+use think\Db;
+use app\common\model\Pass;
+
+class Group
+{
+    function run()
+    {
+
+        $config = config('api_config');
+        $dateData = getTargetDate();
+        $token = getAccessToken();
+
+        $url = $config['host_url'] . "/api/cfas/v2/countGroup/groups/page";
+
+        $pageNo = 1;
+        $pageSize = 1;
+
+        $requestData = [];
+        while (1) {
+
+            $dataArr = [
+                "regionId"=> "root000000",
+                "isCascade"=> 1,
+                "groupType"=> 0,
+                "statType"=> 0,
+                "pageNo"=> $pageNo,
+                "pageSize"=> $pageSize
+            ];
+
+            $json_data = json_encode($dataArr);
+            $result = postToken($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) {
+
+                $insert = [
+                    'groupId'           => $value['groupId'],
+                    'groupName'         => $value['groupName'],
+                    'groupType'         => $value['groupType'],
+                    'statType'          => $value['statType'],
+                    'regionId'          => $value['regionId'],
+                    'thirdPartCode'     => $value['thirdPartCode'],
+                    'workStartTime'     => $value['workStartTime'],
+                    'workEndTime'       => $value['workEndTime'],
+                    'holdBase'          => $value['holdBase'],
+                    'earlyWarningValue' => $value['earlyWarningValue'],
+                    'warningValue'      => $value['warningValue'],
+                    'warningSwitch'     => $value['warningSwitch']
+                ];
+
+                $requestData[] = $insert;
+
+                $query = Db::table('bt_passenger_monitor_group')->where('groupId',$value['groupId'])->find();
+                if ($query) continue;
+
+                Db::table('bt_passenger_monitor_group')->insert($insert);
+            }
+
+            # 总条数不够结束循环
+            if (count($list) < $pageSize) break;
+            ++$pageNo;
+        }
+
+        $requestRes = Pass::requestCreateData($requestData,'/api/pass.create/createGroup',$config['host_path']);
+
+        if (!$requestRes['status']) {
+            return $requestRes['msg'];
+        }
+
+        return true;
+    }
+}

web/group.php

@@ -0,0 +1,15 @@
+<?php
+
+// [ 支付通知入口文件 ]
+
+// 手动定义路由
+$_GET['s'] = '/task/group/run';
+
+// 定义运行目录
+define('WEB_PATH', __DIR__ . '/');
+
+// 定义应用目录
+define('APP_PATH', WEB_PATH . '../source/application/');
+
+// 加载框架引导文件
+require APP_PATH . '../thinkphp/start.php';