From db8816c1a2cac6b4848ce575ece11876b4bd3929 Mon Sep 17 00:00:00 2001
From: wanghongjun <1445693971@qq,com>
Date: Mon, 23 Oct 2023 15:22:30 +0800
Subject: [PATCH] =?UTF-8?q?=E5=87=8F=E5=8E=BB250=E4=B8=87=E8=99=9A?=
 =?UTF-8?q?=E6=8B=9F=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 web/handle_data.php | 242 ++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 242 insertions(+)
 create mode 100644 web/handle_data.php

diff --git a/web/handle_data.php b/web/handle_data.php
new file mode 100644
index 0000000..c5043d5
--- /dev/null
+++ b/web/handle_data.php
@@ -0,0 +1,242 @@
+<?php
+use app\common\dm\Dm;
+require_once __DIR__ . '../../source/application/common/dm/Dm.php';
+require_once __DIR__ . '../../source/thinkphp/helper.php';
+require_once __DIR__ . '../../source/thinkphp/library/think/Config.php';
+require_once __DIR__ . '../../source/application/common.php';
+$config = require_once __DIR__ . '../../source/application/database.php';
+
+
+$dm = new Dm($config['connections']['dm']);
+
+$sumNum = 2500000;
+$monthNum = 7;
+$y = 2023;
+
+
+$tyg = get_pass($dm,'110',$y,$monthNum); // 体育场 <-- replace -->
+$tyc = get_pass($dm,'210',$y,$monthNum); // 体育馆 <-- replace -->
+$yyg = get_pass($dm,'310',$y,$monthNum); // 游泳馆 <-- replace -->
+$bwg = get_pass($dm,'510',$y,$monthNum); // 劳务博物馆 <-- replace -->
+$tsg = get_lib($dm,'baz001',$y,$monthNum); // 图书馆 <-- replace -->
+$whg = get_lib($dm,'BAF055',$y,$monthNum); // 文化馆 <-- replace -->
+
+$allSum = $tyg + $tyc + $yyg + $bwg + $tsg + $whg;
+
+
+$tyHandleData = [
+    '110' => round($tyg/$allSum,4),
+    '210' => round($tyc/$allSum,4),
+    '310' => round($yyg/$allSum,4),
+    '510' => round($bwg/$allSum,4)
+];
+
+$whHandleData = [
+    'baz001' => round($tsg/$allSum,4),
+    'BAF055' => round($whg/$allSum,4)
+];
+
+# ---------------------------- 体育 ----------------------------- #
+
+foreach ($tyHandleData as $groupId => $rate) {
+
+    $tyYearSum = 0;
+
+    # 月度
+    for ($i = 1; $i <= $monthNum; $i++) {
+
+        $flowInNum = round($sumNum * $rate / $monthNum);
+
+        $tyYearSum += $flowInNum;
+
+        $iStr = strlen($i) == 1 ? '0'.$i : $i;
+
+        $statTime = "{$y}-{$iStr}-01T00:00:00.000+08:00";
+
+        $queryWhereAll = ['groupId' => $groupId,'granularity' => 'monthly','statTime' => $statTime,'date'=>'month'];
+        $queryAll = $dm->find('bt_passenger_flow_all',$queryWhereAll);
+        if ($queryAll) {
+
+            $upData = [
+                'flowInNum' => $queryAll['flowInNum'] - $flowInNum,
+                'noRepeatInNum' => $queryAll['noRepeatInNum'] - $flowInNum
+            ];
+            $dm->update('bt_passenger_flow_all',$upData,'"id" = ' . "'{$queryAll['id']}'");
+        }
+
+        $queryWhere = ['groupId' => $groupId,'granularity' => 'monthly','statTime' => $statTime];
+        $query = $dm->find('bt_passenger_flow',$queryWhere);
+
+        if ($query) {
+
+            $upData = [
+                'flowInNum' => $query['flowInNum'] - $flowInNum,
+                'noRepeatInNum' => $query['noRepeatInNum'] - $flowInNum
+            ];
+            $dm->update('bt_passenger_flow',$upData,'"id" = ' . "'{$query['id']}'");
+        }
+    }
+
+    # 年度
+    $queryWhereSumAll = ['groupId' => $groupId,'granularity' => 'yearly','statTime' => ['>=',"{$y}-01-01T00:00:00.000+08:00"],'date' => 'year'];
+    $querySumAll = $dm->find('bt_passenger_flow_all',$queryWhereSumAll);
+
+    if ($querySumAll) {
+        $updateAll = [
+            'flowInNum' => $querySumAll['flowInNum'] - $tyYearSum,
+            'noRepeatInNum' => $querySumAll['noRepeatInNum'] - $tyYearSum,
+        ];
+
+        $dm->update('bt_passenger_flow_all',$updateAll,'"id" = ' . "'{$querySumAll['id']}'");
+    }
+
+    $queryWhereSum = ['groupId' => $groupId,'granularity' => 'yearly','statTime' => ['>=',"{$y}-01-01T00:00:00.000+08:00"]];
+    $querySum = $dm->find('bt_passenger_flow',$queryWhereSum);
+
+    if ($querySum) {
+
+        $update = [
+            'flowInNum' => $querySum['flowInNum'] - $tyYearSum,
+            'noRepeatInNum' => $querySum['noRepeatInNum']- $tyYearSum,
+        ];
+
+        $dm->update('bt_passenger_flow',$update,'"id" = ' . "'{$querySum['id']}'");
+    }
+    echo $groupId;
+    echo "<br>";
+    echo $tyYearSum;
+    echo "<br>";
+    echo "----------------------------------";
+    echo "<br>";
+}
+echo "<h1>体育结束....</h1>";
+# ---------------------------- 体育end ----------------------------- #
+
+# ---------------------------- 文化 ----------------------------- #
+
+$whYearSum = [
+    'baz001' => 0,
+    'BAF055' => 0,
+    'lib001' => 0
+];
+
+$whMonthRate = [];
+
+foreach ($whHandleData as $group_id => $whRate) {
+
+
+    $groupData = [];
+    $groupDataSumNum = 0;
+    for ($i = 1; $i <= $monthNum; $i++) {
+
+        $str = strlen($i) == 1 ? '0' . $i : $i;
+
+        $days = date('t', strtotime($y . '-' . $str . '-01'));
+        $start = date("{$y}-{$str}-01 ") ."00:00:00";
+        $end = date("{$y}-{$str}-{$days} ") ."23:59:59";
+        $queryWhere = ' "date" = ' . "'month'" . ' and "group_id" = ' . "'{$group_id}'" . ' and "create_time" >= ' . "'{$start}'" . ' and "create_time" <= ' . "'{$end}'";
+        $query      = $dm->find('bt_library_data', $queryWhere);
+        if ($query) {
+            $groupData[$i]['id'] = $query['id'];
+            $groupData[$i]['incount'] = $query['incount'];
+            $groupData[$i]['outcount'] = $query['outcount'];
+            $groupDataSumNum += $query['incount'];
+        }
+    }
+
+    foreach ($groupData as &$item) {
+        $item['rate'] = round($item['incount']/$groupDataSumNum,4);
+    }
+
+    $whMonthRate[$group_id] = $groupData;
+}
+
+# 文化月度
+for ($i = 1; $i <= $monthNum; $i++) {
+
+    $str = strlen($i) == 1 ? '0' . $i : $i;
+
+    $libInCount = 0;
+
+    $days = date('t', strtotime($y . '-' . $str . '-01'));
+    $start = date("{$y}-{$str}-01 ") ."00:00:00";
+    $end = date("{$y}-{$str}-{$days} ") ."23:59:59";
+
+    foreach ($whHandleData as $group_id => $whRate) {
+
+        $query = $whMonthRate[$group_id][$i];
+
+        if ($query) {
+
+            $incount = round($sumNum * $whRate * $query['rate']);
+
+            $libInCount += $incount;
+            $whYearSum[$group_id] += $incount;
+
+            $upData = [
+                'incount' => $query['incount'] - $incount,
+                'outcount' => $query['outcount'] - $incount,
+            ];
+
+            $dm->update('bt_library_data',$upData,'"id" = ' . "'{$query['id']}'");
+        }
+    }
+
+    $queryWhere2 = ' "date" = ' . "'month'" . ' and "group_id" = ' . "'lib001'" . ' and "create_time" >= ' . "'{$start}'" . ' and "create_time" <= ' . "'{$end}'" ;
+    $query2 = $dm->find('bt_library_data',$queryWhere2);
+    if ($query2) {
+
+        $whYearSum['lib001'] += $libInCount;
+
+        $lib001 = [
+            'incount' => $query2['incount'] - $libInCount,
+            'outcount' => $query2['outcount'] - $libInCount
+        ];
+        $dm->update('bt_library_data', $lib001,'"id" = ' . "'{$query2['id']}'");
+    }
+}
+
+# 文化年度
+foreach ($whYearSum as $group_id => $yearSumInCount) {
+
+    $whQueryWhere = ['date' => 'year', 'group_id' => $group_id, 'create_time' => ['>=',date("Y-01-01 ") ."00:00:00"]];
+    $whQuery = $dm->find("bt_library_data",$whQueryWhere);
+
+    if ($whQuery) {
+        $baz001 = [
+            'incount' => $whQuery['incount'] - $yearSumInCount,
+            'outcount' => $whQuery['outcount'] - $yearSumInCount
+        ];
+        $dm->update('bt_library_data',$baz001,'"id" = ' . "'{$whQuery['id']}'");
+    }
+    echo $group_id;
+    echo "<br>";
+    echo $yearSumInCount;
+    echo "<br>";
+    echo "----------------------------------";
+    echo "<br>";
+}
+echo "<h1>文化结束....</h1>";
+
+# ---------------------------- 文化end ----------------------------- #
+
+function get_lib($dm,$group_id,$y,$month) {
+    $str = strlen($month) == 1 ? '0' . $month : $month;
+    $days = date('t', strtotime($y . '-' . $str . '-01'));
+    $start = date("{$y}-01-01 ") ."00:00:00";
+    $end = date("{$y}-{$str}-{$days} ") ."23:59:59";
+
+    $whQueryWhere = ' "date" = ' . "'month'" . ' and "group_id" = ' . "'{$group_id}'" . ' and "create_time" >= ' . "'{$start}'" . ' and "create_time" <= ' . "'{$end}'" ;
+    $whQuery = $dm->find("bt_library_data",$whQueryWhere,'SUM("incount") as sum_incount');
+    return $whQuery ? $whQuery['SUM_INCOUNT'] : 0;
+}
+
+function get_pass($dm,$groupId,$y,$month) {
+    $str = strlen($month) == 1 ? '0' . $month : $month;
+    $days = date('t', strtotime($y . '-' . $str . '-01'));
+    $start = date("{$y}-01-01") ."T00:00:00.000+08:00";
+    $end = date("{$y}-{$str}-{$days}") ."T23:59:59.000+08:00";
+    $tyQueryWhere = ' "date" = ' . "'month'" . ' and "granularity" = ' . "'monthly'" . ' and "groupId" = ' . "'{$groupId}'" . ' and "statTime" >= ' . "'{$start}'" . ' and "statTime" <= ' . "'{$end}'" ;
+    $tyQuery = $dm->find("bt_passenger_flow_all",$tyQueryWhere,'SUM("flowInNum") as sum_incount');
+    return $tyQuery ? $tyQuery['SUM_INCOUNT'] : 0;
+}
\ No newline at end of file