敏捷与稳定并行：Scrum看板+BPM工具选型指南

"""
端到端价值流平台核心实现
连接Scrum看板与BPM系统，实现自动化同步与可视化
"""

class ValueStreamPlatform:
    """统一价值流平台"""
    
    def __init__(self, scrum_board, bpm_system):
        self.scrum = scrum_board
        self.bpm = bpm_system
        self.rules = []
    
    def sync_on_complete(self, task_id, process_template):
        """任务完成时触发业务流程"""
        task = self.scrum.get_task(task_id)
        
        if task['status'] == 'completed':
            process = self.bpm.create_process(
                template=process_template,
                data={'task': task}
            )
            self.scrum.update_task(task_id, {'bpm_id': process['id']})
            return process
    
    def sync_on_process_update(self, process_id):
        """流程更新时同步任务状态"""
        process = self.bpm.get_process(process_id)
        task_id = process['data']['task']['id']
        
        self.scrum.update_task(task_id, {
            'process_status': process['status'],
            'sync_time': self._now()
        })
    
    def get_dashboard(self):
        """获取统一仪表板数据"""
        scrum_data = self.scrum.get_metrics()
        bpm_data = self.bpm.get_metrics()
        
        return {
            'value_stream': self._build_value_stream(scrum_data, bpm_data),
            'bottlenecks': self._find_bottlenecks(scrum_data, bpm_data)
        }
    
    def add_rule(self, trigger, action):
        """添加自动化规则"""
        self.rules.append({
            'trigger': trigger,
            'action': action
        })
    
    def _build_value_stream(self, scrum_data, bpm_data):
        """构建价值流视图"""
        return [
            {'stage': '开发', 'duration': scrum_data['avg_cycle_time']},
            {'stage': '审批', 'duration': bpm_data['avg_process_time']},
            {'stage': '上线', 'duration': self._calc_handoff_time(scrum_data, bpm_data)}
        ]
    
    def _find_bottlenecks(self, scrum_data, bpm_data):
        """识别瓶颈"""
        bottlenecks = []
        
        if bpm_data['avg_wait_time'] > scrum_data['avg_cycle_time']:
            bottlenecks.append('审批等待时间过长')
        
        if scrum_data['handoff_count'] > 3:
            bottlenecks.append('交接次数过多')
        
        return bottlenecks
    
    def _calc_handoff_time(self, scrum_data, bpm_data):
        """计算交接时间"""
        return abs(scrum_data['completion_time'] - bpm_data['start_time'])
    
    def _now(self):
        from datetime import datetime
        return datetime.now()

# 使用示例
if __name__ == "__main__":
    # 初始化平台
    platform = ValueStreamPlatform(ScrumBoard(), BPMSystem())
    
    # 设置自动化规则：任务完成 → 触发审批流程
    platform.add_rule(
        trigger={'event': 'task_complete', 'type': 'legal'},
        action={'type': 'start_process', 'template': 'legal_approval'}
    )
    
    # 手动触发同步
    platform.sync_on_complete('TASK-123', 'market_release')
    
    # 查看瓶颈
    dashboard = platform.get_dashboard()
    print(f"瓶颈点: {dashboard['bottlenecks']}")