add assistant_performance

新增医助个人业绩执行：add_assistant_performance_menu.sql
2026-05-19 14:41:14 +08:00
parent 9208e7eaaa
commit 1cb00e9fbe
5 changed files with 421 additions and 0 deletions
@@ -0,0 +1,106 @@
+<?php
+declare(strict_types=1);
+
+namespace app\adminapi\logic\stats;
+
+use think\facade\Db;
+
+class AssistantPerformanceLogic
+{
+    /** 履约完成 */
+    private const FULFILLMENT_COMPLETED = 3;
+
+    public static function overview(array $params, int $adminId, array $adminInfo): array
+    {
+        // 时间范围解析
+        $timeType = $params['time_type'] ?? 'month';
+        $today = date('Y-m-d');
+
+        switch ($timeType) {
+            case 'today':
+                $startDate = $today;
+                $endDate = $today;
+                break;
+            case 'yesterday':
+                $startDate = date('Y-m-d', strtotime('-1 day'));
+                $endDate = $startDate;
+                break;
+            case 'week':
+                $startDate = date('Y-m-d', strtotime('-6 days'));
+                $endDate = $today;
+                break;
+            case 'month':
+                $startDate = date('Y-m-d', strtotime('-29 days'));
+                $endDate = $today;
+                break;
+            case 'custom':
+                $startDate = $params['start_date'] ?? $today;
+                $endDate = $params['end_date'] ?? $today;
+                break;
+            default:
+                $startDate = date('Y-m-d', strtotime('-29 days'));
+                $endDate = $today;
+        }
+
+        $startTs = strtotime($startDate . ' 00:00:00');
+        $endTs = strtotime($endDate . ' 23:59:59');
+
+        // 查询当前医助创建的、履约已完成的处方业务订单
+        $baseQuery = Db::name('tcm_prescription_order')
+            ->where('delete_time IS NULL')
+            ->where('diagnosis_id', '>', 0)
+            ->where('creator_id', $adminId)
+            ->where('fulfillment_status', self::FULFILLMENT_COMPLETED)
+            ->where('create_time', '>=', $startTs)
+            ->where('create_time', '<=', $endTs);
+
+        // 业绩总额
+        $totalAmount = (clone $baseQuery)->sum('amount');
+
+        // 有效订单数
+        $totalCount = (clone $baseQuery)->count();
+
+        // 按日期分组的折线图数据
+        $dailyData = (clone $baseQuery)
+            ->field("FROM_UNIXTIME(create_time, '%Y-%m-%d') as date_label, SUM(amount) as daily_amount, COUNT(*) as daily_count")
+            ->group('date_label')
+            ->order('date_label', 'asc')
+            ->select()
+            ->toArray();
+
+        // 补全日期范围内的空日期
+        $dateMap = [];
+        foreach ($dailyData as $row) {
+            $dateMap[$row['date_label']] = [
+                'amount' => round((float)$row['daily_amount'], 2),
+                'count' => (int)$row['daily_count'],
+            ];
+        }
+
+        $dates = [];
+        $amounts = [];
+        $counts = [];
+        $cursor = strtotime($startDate);
+        $endCursor = strtotime($endDate);
+        while ($cursor <= $endCursor) {
+            $d = date('Y-m-d', $cursor);
+            $dates[] = substr($d, 5); // MM-DD
+            $amounts[] = $dateMap[$d]['amount'] ?? 0;
+            $counts[] = $dateMap[$d]['count'] ?? 0;
+            $cursor = strtotime('+1 day', $cursor);
+        }
+
+        return [
+            'date_range' => [$startDate, $endDate],
+            'summary' => [
+                'total_amount' => round((float)$totalAmount, 2),
+                'total_count' => (int)$totalCount,
+            ],
+            'chart' => [
+                'dates' => $dates,
+                'amounts' => $amounts,
+                'counts' => $counts,
+            ],
+        ];
+    }
+}