import datetime

def get_formatted_timestamp():
    """
    获取指定格式的时间戳: YYYY-MM-DD HH:MM:SS,ms
    例如: 2025-05-16 14:44:09,324
    """
    now = datetime.datetime.now()
    # 格式化日期和时间部分
    timestamp_str = now.strftime("%Y-%m-%d %H:%M:%S")
    # 获取毫秒部分,并格式化为3位数字
    milliseconds = now.microsecond // 1000
    milliseconds_str = f"{milliseconds:03d}"
    # 组合最终格式
    return f"{timestamp_str},{milliseconds_str}"

def add_state_flow_entry(process_item, state_name, msg, status_val="pending"):
    """辅助函数,用于向 stateFlow 列表添加条目。"""
    entry = {
        "stateName": state_name, # 状态名称
        "timestamp": get_formatted_timestamp(), # 时间戳
        "msg": msg, # 消息
        "status": status_val # 状态值: "pending", "success", "fail", "skipped"
    }
    process_item["stateFlow"].append(entry)
    process_item["currentState"] = state_name # 更新整体状态
    # logging.info(f"[流程 {process_item.get('id', 'N/A')}][{state_name}]: {msg} (状态: {status_val})")