wanghongjun
2 years ago
1 changed files with 242 additions and 0 deletions
@ -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; |
|||
} |
|||
Loading…
Reference in new issue