代办任务

2026-05-05 12:42:09 +08:00
parent 1d6a2b9cbf
commit 0da27ed745
14 changed files with 1215 additions and 9 deletions
@@ -0,0 +1,207 @@
+<?php
+
+declare(strict_types=1);
+
+namespace app\command;
+
+use app\common\model\auth\Admin;
+use app\common\model\tcm\Diagnosis;
+use app\common\model\tcm\DiagnosisTodo;
+use app\common\service\wechat\WechatWorkAppMessageService;
+use think\console\Command;
+use think\console\Input;
+use think\console\Output;
+use think\facade\Db;
+use think\facade\Log;
+
+/**
+ * 诊单待办事项 - 企业微信定时推送
+ *
+ * 使用方法：
+ *   php think tcm:diagnosis-todo-notify
+ *
+ * 推荐 cron（每分钟执行）：
+ *   * * * * * cd /path/to/server && php think tcm:diagnosis-todo-notify >> /var/log/zyt-todo.log 2>&1
+ *
+ * 行为：
+ *   1. 取出 status=0 且 remind_time<=now 的待办，按 remind_time asc，限 200 条
+ *   2. 每条用乐观锁 (update set status=1 where id=? and status=0) 抢占，避免并发重复推送
+ *   3. 找创建人 admin.work_wechat_userid，未绑定 → status=3 + error
+ *   4. 调 WechatWorkAppMessageService::sendTextToUser，失败 → status=3 + error（终态，不重试）
+ *   5. 整批不中断；输出 处理 N / 成功 X / 失败 Y / 跳过未绑定 Z
+ */
+class DiagnosisTodoNotify extends Command
+{
+    /** 单次扫描最大条数 */
+    private const BATCH_LIMIT = 200;
+
+    protected function configure()
+    {
+        $this->setName('tcm:diagnosis-todo-notify')
+            ->setDescription('诊单待办事项：扫描到点的待执行项并向创建人发送企业微信消息');
+    }
+
+    protected function execute(Input $input, Output $output): int
+    {
+        $startTs = microtime(true);
+        $now     = time();
+
+        $output->writeln('[' . date('Y-m-d H:i:s', $now) . '] 开始扫描诊单待办事项...');
+
+        $totalProcessed   = 0;
+        $totalSent        = 0;
+        $totalFailed      = 0;
+        $totalSkipped     = 0;  // 被并发抢占
+        $totalUnbound     = 0;  // 创建人未绑定企微（计入 failed）
+
+        try {
+            $todoTable = (new DiagnosisTodo())->getTable();
+
+            $rows = Db::name(self::stripTablePrefix($todoTable))
+                ->where('status', DiagnosisTodo::STATUS_PENDING)
+                ->where('remind_time', '<=', $now)
+                ->whereNull('delete_time')
+                ->order('remind_time', 'asc')
+                ->limit(self::BATCH_LIMIT)
+                ->select()
+                ->toArray();
+
+            $output->writeln('待处理数量：' . count($rows));
+
+            foreach ($rows as $row) {
+                $totalProcessed++;
+                $todoId = (int) ($row['id'] ?? 0);
+                if ($todoId <= 0) {
+                    continue;
+                }
+
+                try {
+                    // 乐观锁：抢占成功时影响 1 行；并发场景下另一个进程已抢走则影响 0 行 → 跳过
+                    $affected = Db::name(self::stripTablePrefix($todoTable))
+                        ->where('id', $todoId)
+                        ->where('status', DiagnosisTodo::STATUS_PENDING)
+                        ->update([
+                            'status'      => DiagnosisTodo::STATUS_SENT,
+                            'notified_at' => $now,
+                            'update_time' => $now,
+                        ]);
+
+                    if ($affected <= 0) {
+                        $totalSkipped++;
+                        continue;
+                    }
+
+                    // 取创建人 work_wechat_userid
+                    $creatorId = (int) ($row['creator_id'] ?? 0);
+                    $wxId      = '';
+                    if ($creatorId > 0) {
+                        $wxId = (string) Admin::where('id', $creatorId)->value('work_wechat_userid');
+                    }
+
+                    if ($wxId === '') {
+                        $this->markFailed($todoTable, $todoId, '创建人未绑定企业微信 userid');
+                        $totalUnbound++;
+                        $totalFailed++;
+                        continue;
+                    }
+
+                    // 拼推送文本
+                    $text = $this->buildText($row);
+
+                    $res = WechatWorkAppMessageService::sendTextToUser($wxId, $text);
+                    if (!($res['ok'] ?? false)) {
+                        $errMsg = (string) ($res['message'] ?? '企业微信推送失败');
+                        $this->markFailed($todoTable, $todoId, $errMsg);
+                        $totalFailed++;
+                        continue;
+                    }
+
+                    $totalSent++;
+                } catch (\Throwable $e) {
+                    Log::error('诊单待办推送异常 todo_id=' . $todoId . ' msg=' . $e->getMessage());
+                    try {
+                        $this->markFailed($todoTable, $todoId, '系统异常: ' . $e->getMessage());
+                    } catch (\Throwable $ee) {
+                        Log::error('回写失败状态出错 todo_id=' . $todoId . ' msg=' . $ee->getMessage());
+                    }
+                    $totalFailed++;
+                }
+            }
+        } catch (\Throwable $e) {
+            Log::error('诊单待办批处理异常: ' . $e->getMessage());
+            $output->error('批处理异常: ' . $e->getMessage());
+
+            return 1;
+        }
+
+        $duration = round(microtime(true) - $startTs, 3);
+        $output->writeln(sprintf(
+            '处理完成。总数: %d, 成功: %d, 失败: %d (其中未绑定企微: %d), 并发跳过: %d, 耗时: %ss',
+            $totalProcessed,
+            $totalSent,
+            $totalFailed,
+            $totalUnbound,
+            $totalSkipped,
+            $duration
+        ));
+
+        return 0;
+    }
+
+    /**
+     * 拼接推送文本
+     *
+     * @param array<string,mixed> $row 待办记录原始行
+     */
+    private function buildText(array $row): string
+    {
+        $patientName = '';
+        $diagnosisId = (int) ($row['diagnosis_id'] ?? 0);
+        if ($diagnosisId > 0) {
+            $patientName = (string) Diagnosis::where('id', $diagnosisId)->value('patient_name');
+        }
+
+        $remindAt = (int) ($row['remind_time'] ?? 0);
+        $content  = trim((string) ($row['content'] ?? ''));
+
+        $lines = [
+            '【患者跟踪提醒】',
+            '患者：' . ($patientName !== '' ? $patientName : '-'),
+            '时间：' . ($remindAt > 0 ? date('Y-m-d H:i', $remindAt) : '-'),
+            '内容：' . ($content !== '' ? $content : '-'),
+            '— 二中心跟踪系统',
+        ];
+
+        return implode("\n", $lines);
+    }
+
+    /**
+     * 标记一条待办为「发送失败」，写入 error 字段
+     */
+    private function markFailed(string $todoTable, int $todoId, string $errMsg): void
+    {
+        $errMsg = mb_substr($errMsg, 0, 500);
+        Db::name(self::stripTablePrefix($todoTable))
+            ->where('id', $todoId)
+            ->update([
+                'status'      => DiagnosisTodo::STATUS_FAILED,
+                'error'       => $errMsg,
+                'update_time' => time(),
+            ]);
+    }
+
+    /**
+     * Db::name() 接收的是不带前缀的表名，BloodRecord 等 Model::getTable() 返回的是带前缀的全名。
+     * 这里去掉首段 `<prefix>_`。注意：项目实际前缀是 `zyt_`，但 think-orm 的 Db::name()
+     * 内部会用 config('database.prefix') 自动拼回，所以这里只需剥离一次即可。
+     */
+    private static function stripTablePrefix(string $tableWithPrefix): string
+    {
+        $prefix = (string) config('database.connections.mysql.prefix', '');
+        if ($prefix !== '' && str_starts_with($tableWithPrefix, $prefix)) {
+            return substr($tableWithPrefix, strlen($prefix));
+        }
+
+        return $tableWithPrefix;
+    }
+}