imporving for: Automatically saving workflows can result in overwriting changes made by others #3610

[caoping6]

Self Checks

• I have searched for existing issues search for existing issues, including closed ones.
• I confirm that I am using English to submit this report (我已阅读并同意 Language Policy).
• [FOR CHINESE USERS] 请务必使用英文提交 Issue，否则会被关闭。谢谢！:)
• Please do not modify this template :) and fill in all the required fields.

1. Is this request related to a challenge you're experiencing? Tell me about your story.

existing discussion:

solution:
I chose Redis distributed locks and added buttons for acquiring/releasing locks on the page where workflows are edited

add api:
`
@console_ns.route("/apps/uuid:app_id/workflows/draft/lock")
class WorkflowLockApi(Resource):
@console_ns.doc("get_workflow_lock_status")
@console_ns.doc(description="Get workflow edit lock status")
@console_ns.doc(params={"app_id": "Application ID"})
@console_ns.response(200, "Lock status retrieved successfully")
@setup_required
@login_required
@account_initialization_required
@get_app_model(mode=[AppMode.ADVANCED_CHAT, AppMode.WORKFLOW])
def get(self, app_model: App):
"""
Get workflow edit lock status
"""
current_user, _ = current_account_with_tenant()
workflow_service = WorkflowService()
lock_status = workflow_service.get_workflow_lock_status(app_model)
lock_status["is_locked_by_me"] = workflow_service.check_workflow_lock(app_model, current_user)
return lock_status

@console_ns.doc("acquire_workflow_lock")
@console_ns.doc(description="Acquire workflow edit lock")
@console_ns.doc(params={"app_id": "Application ID"})
@console_ns.response(200, "Lock acquired successfully")
@console_ns.response(409, "Lock already held by another user")
@setup_required
@login_required
@account_initialization_required
@get_app_model(mode=[AppMode.ADVANCED_CHAT, AppMode.WORKFLOW])
@edit_permission_required
def post(self, app_model: App):
    """
    Acquire workflow edit lock
    """
    current_user, _ = current_account_with_tenant()
    workflow_service = WorkflowService()

    # Try to acquire lock
    acquired = workflow_service.acquire_workflow_lock(app_model, current_user)

    if not acquired:
        lock_status = workflow_service.get_workflow_lock_status(app_model)
        locked_by_name = lock_status["locked_by_name"] or "其他用户"
        return {
            "message": f"工作流正在被 {locked_by_name} 编辑",
            "locked_by": lock_status["locked_by"],
            "locked_by_name": locked_by_name,
        }, 409

    return {
        "result": "success",
        "message": "已获取编辑锁",
    }

@console_ns.doc("release_workflow_lock")
@console_ns.doc(description="Release workflow edit lock")
@console_ns.doc(params={"app_id": "Application ID"})
@console_ns.response(200, "Lock released successfully")
@console_ns.response(403, "Lock not held by current user")
@setup_required
@login_required
@account_initialization_required
@get_app_model(mode=[AppMode.ADVANCED_CHAT, AppMode.WORKFLOW])
@edit_permission_required
def delete(self, app_model: App):
    """
    Release workflow edit lock
    """
    current_user, _ = current_account_with_tenant()
    workflow_service = WorkflowService()

    released = workflow_service.release_workflow_lock(app_model, current_user)

    if not released:
        return {"message": "您没有持有编辑锁"}, 403

    return {
        "result": "success",
        "message": "已释放编辑锁",
    }

`

2. Additional context or comments

No response

3. Can you help us with this feature?

• I am interested in contributing to this feature.