通达OA典型功能实现原理与最佳实践

class FlowEngine {
    public function createInstance($flow_id, $uid) {
        global $td;
        
        // 创建流程实例
        $sql = "INSERT INTO flow_instance (flow_id, creator_uid, status) 
                VALUES ($flow_id, $uid, 'running')";
        $td->query($sql);
        $instance_id = $td->insert_id();
        
        // 获取首节点
        $result = $td->query("SELECT node_id FROM flow_node WHERE flow_id = $flow_id AND node_type = 'start'");
        $node = $td->fetch_array($result);
        
        // 创建首节点任务
        $this->createTask($instance_id, $node['node_id']);
        
        return $instance_id;
    }
    
    public function completeTask($task_id, $action, $comment = '') {
        global $td;
        
        // 获取任务信息
        $result = $td->query("SELECT * FROM flow_task WHERE task_id = $task_id");
        $task = $td->fetch_array($result);
        
        // 更新任务状态
        $td->query("UPDATE flow_task SET status = 'completed', action = '$action', 
                    comment = '$comment', complete_time = NOW() WHERE task_id = $task_id");
        
        // 获取下一节点
        $next_node = $this->getNextNode($task['flow_id'], $task['node_id'], $action);
        
        if ($next_node) {
            // 创建下一节点任务
            $this->createTask($task['instance_id'], $next_node);
        } else {
            // 流程结束
            $td->query("UPDATE flow_instance SET status = 'completed', end_time = NOW() 
                        WHERE instance_id = " . $task['instance_id']);
        }
    }
    
    private function createTask($instance_id, $node_id) {
        global $td;
        
        // 获取节点信息
        $result = $td->query("SELECT * FROM flow_node WHERE node_id = $node_id");
        $node = $td->fetch_array($result);
        
        // 获取处理人
        $assignees = $this->getAssignees($node['assignee_type'], $node['assignee_ids']);
        
        // 创建任务
        foreach ($assignees as $uid) {
            $td->query("INSERT INTO flow_task (instance_id, node_id, uid, status) 
                        VALUES ($instance_id, $node_id, $uid, 'pending')");
        }
        
        // 发送通知
        $this->sendNotification($instance_id, $node_id, $assignees);
    }
    
    private function getNextNode($flow_id, $current_node, $action) {
        global $td;
        
        $sql = "SELECT to_node FROM flow_transition WHERE flow_id = $flow_id 
                AND from_node = $current_node AND action = '$action'";
        $result = $td->query($sql);
        
        if ($td->num_rows($result) > 0) {
            $row = $td->fetch_array($result);
            return $row['to_node'];
        }
        
        return null;
    }
}

function getScheduleList($uid, $start_date, $end_date) {
    global $td;
    
    $sql = "SELECT s.* FROM schedule s 
            LEFT JOIN schedule_user su ON s.schedule_id = su.schedule_id 
            WHERE su.uid = $uid 
            AND s.start_time >= '$start_date 00:00:00' 
            AND s.end_time <= '$end_date 23:59:59' 
            ORDER BY s.start_time";
    
    $result = $td->query($sql);
    $schedules = array();
    
    while ($row = $td->fetch_array($result)) {
        // 处理重复日程
        if ($row['repeat_type']) {
            $repeats = getRepeatSchedules($row, $start_date, $end_date);
            $schedules = array_merge($schedules, $repeats);
        } else {
            $schedules[] = $row;
        }
    }
    
    return $schedules;
}

function getRepeatSchedules($schedule, $start_date, $end_date) {
    $repeats = array();
    $current_date = date('Y-m-d', strtotime($schedule['start_time']));
    
    while ($current_date <= $end_date) {
        if ($current_date >= $start_date) {
            $repeat = $schedule;
            $repeat['start_time'] = $current_date . ' ' . date('H:i:s', strtotime($schedule['start_time']));
            $repeat['end_time'] = $current_date . ' ' . date('H:i:s', strtotime($schedule['end_time']));
            $repeats[] = $repeat;
        }
        
        // 计算下一个日期
        switch ($schedule['repeat_type']) {
            case 'daily':
                $current_date = date('Y-m-d', strtotime($current_date . ' +1 day'));
                break;
            case 'weekly':
                $current_date = date('Y-m-d', strtotime($current_date . ' +1 week'));
                break;
            case 'monthly':
                $current_date = date('Y-m-d', strtotime($current_date . ' +1 month'));
                break;
            case 'yearly':
                $current_date = date('Y-m-d', strtotime($current_date . ' +1 year'));
                break;
        }
        
        // 检查结束日期
        if ($schedule['repeat_end_date'] && $current_date > $schedule['repeat_end_date']) {
            break;
        }
    }
    
    return $repeats;
}

function processScheduleReminders() {
    global $td;
    
    $now = date('Y-m-d H:i:s');
    
    // 查询待提醒日程
    $sql = "SELECT * FROM schedule s 
            LEFT JOIN schedule_remind sr ON s.schedule_id = sr.schedule_id 
            WHERE s.start_time > '$now' 
            AND sr.remind_time <= '$now' 
            AND sr.is_reminded = 0";
    
    $result = $td->query($sql);
    
    while ($row = $td->fetch_array($result)) {
        // 获取参与人
        $user_result = $td->query("SELECT uid FROM schedule_user WHERE schedule_id = " . $row['schedule_id']);
        
        while ($user_row = $td->fetch_array($user_result)) {
            // 发送提醒
            send_reminder($user_row['uid'], $row);
        }
        
        // 标记已提醒
        $td->query("UPDATE schedule_remind SET is_reminded = 1 WHERE schedule_id = " . $row['schedule_id']);
    }
}

function send_reminder($uid, $schedule) {
    // 发送短信提醒
    $sms_content = "【通达OA】您有一个日程提醒：{$schedule['subject']}，时间：{$schedule['start_time']}";
    send_sms($uid, $sms_content);
    
    // 发送站内消息
    $msg_content = "您有一个日程提醒：<a href='schedule_detail.php?id={$schedule['schedule_id']}'>{$schedule['subject']}</a>";
    send_message($uid, $msg_content);
}

function publishAnnouncement($title, $content, $dept_ids, $user_ids, $expire_days = 7) {
    global $td;
    
    $publisher_uid = $_SESSION['uid'];
    $publish_time = date('Y-m-d H:i:s');
    $expire_time = date('Y-m-d H:i:s', strtotime("+$expire_days days"));
    
    // 插入公告记录
    $title = $td->escape($title);
    $content = $td->escape($content);
    
    $sql = "INSERT INTO announcement (title, content, publish_time, expire_time, publisher_uid, status) 
            VALUES ('$title', '$content', '$publish_time', '$expire_time', $publisher_uid, 'published')";
    $td->query($sql);
    $announcement_id = $td->insert_id();
    
    // 插入部门关联
    if ($dept_ids) {
        foreach (explode(',', $dept_ids) as $dept_id) {
            if ($dept_id) {
                $td->query("INSERT INTO announcement_dept (announcement_id, dept_id) VALUES ($announcement_id, $dept_id)");
            }
        }
    }
    
    // 插入用户关联
    if ($user_ids) {
        foreach (explode(',', $user_ids) as $uid) {
            if ($uid) {
                $td->query("INSERT INTO announcement_user (announcement_id, uid) VALUES ($announcement_id, $uid)");
            }
        }
    }
    
    // 发送通知
    sendAnnouncementNotification($announcement_id);
    
    return $announcement_id;
}

function sendAnnouncementNotification($announcement_id) {
    global $td;
    
    // 获取目标用户
    $sql = "SELECT DISTINCT u.uid FROM user u 
            LEFT JOIN announcement_dept ad ON u.dept_id = ad.dept_id 
            LEFT JOIN announcement_user au ON u.uid = au.uid 
            WHERE ad.announcement_id = $announcement_id OR au.announcement_id = $announcement_id";
    
    $result = $td->query($sql);
    
    while ($row = $td->fetch_array($result)) {
        // 发送站内消息
        $msg_content = "您有新的公告：<a href='announcement_detail.php?id=$announcement_id'>点击查看</a>";
        send_message($row['uid'], $msg_content);
    }
}

function checkRoomConflict($room_id, $start_time, $end_time, $exclude_meeting_id = null) {
    global $td;
    
    $sql = "SELECT * FROM meeting WHERE room_id = $room_id 
            AND status != 'cancelled' 
            AND start_time < '$end_time' 
            AND end_time > '$start_time'";
    
    if ($exclude_meeting_id) {
        $sql .= " AND meeting_id != $exclude_meeting_id";
    }
    
    $result = $td->query($sql);
    
    return $td->num_rows($result) > 0;
}

function getAvailableRooms($start_time, $end_time, $capacity = 0) {
    global $td;
    
    $sql = "SELECT r.* FROM meeting_room r 
            WHERE r.status = 'available'";
    
    if ($capacity > 0) {
        $sql .= " AND r.capacity >= $capacity";
    }
    
    $result = $td->query($sql);
    $rooms = array();
    
    while ($row = $td->fetch_array($result)) {
        if (!checkRoomConflict($row['room_id'], $start_time, $end_time)) {
            $rooms[] = $row;
        }
    }
    
    return $rooms;
}

function createMeeting($subject, $description, $room_id, $start_time, $end_time, $user_ids) {
    global $td;
    
    // 检查会议室冲突
    if (checkRoomConflict($room_id, $start_time, $end_time)) {
        throw new Exception(_("该时间段会议室已被预订"));
    }
    
    $creator_uid = $_SESSION['uid'];
    
    // 创建会议
    $subject = $td->escape($subject);
    $description = $td->escape($description);
    
    $sql = "INSERT INTO meeting (subject, description, room_id, start_time, end_time, creator_uid, status) 
            VALUES ('$subject', '$description', $room_id, '$start_time', '$end_time', $creator_uid, 'pending')";
    $td->query($sql);
    $meeting_id = $td->insert_id();
    
    // 添加参会人
    foreach (explode(',', $user_ids) as $uid) {
        if ($uid) {
            $role = ($uid == $creator_uid) ? 'organizer' : 'participant';
            $td->query("INSERT INTO meeting_user (meeting_id, uid, role, status) VALUES ($meeting_id, $uid, '$role', 'pending')");
        }
    }
    
    // 创建日程
    createSchedule($meeting_id, $subject, $description, $start_time, $end_time, $user_ids);
    
    // 发送通知
    sendMeetingNotification($meeting_id);
    
    return $meeting_id;
}

function createSchedule($meeting_id, $subject, $description, $start_time, $end_time, $user_ids) {
    global $td;
    
    $sql = "INSERT INTO schedule (subject, description, start_time, end_time, creator_uid) 
            VALUES ('$subject', '$description', '$start_time', '$end_time', " . $_SESSION['uid'] . ")";
    $td->query($sql);
    $schedule_id = $td->insert_id();
    
    foreach (explode(',', $user_ids) as $uid) {
        if ($uid) {
            $td->query("INSERT INTO schedule_user (schedule_id, uid) VALUES ($schedule_id, $uid)");
        }
    }
    
    return $schedule_id;
}