1
// 文件: .../module/notification/SendNotificationModule.kt
2

3
package com.chaomixian.vflow.core.workflow.module.notification
4

5
import com.chaomixian.vflow.core.module.BaseModule
6
// ... 其他 imports
7

8
class SendNotificationModule : BaseModule() {
9
    // 模块代码将在这里填充
10
}

1
import com.chaomixian.vflow.R
2
import com.chaomixian.vflow.core.module.ActionMetadata
3

4
// ...
5
override val id = "vflow.notification.send_notification"
6
override val metadata = ActionMetadata(
7
    name = "发送通知",
8
    description = "在系统通知栏中创建一个自定义通知。",
9
    iconRes = R.drawable.rounded_notifications_unread_24, // 使用一个合适的图标
10
    category = "应用与系统" // 这会决定它在动作选择器中的分组
11
)
12
// ...

1
import com.chaomixian.vflow.core.module.InputDefinition
2
import com.chaomixian.vflow.core.module.ParameterType
3
import com.chaomixian.vflow.core.module.TextVariable
4

5
// ...
6
override fun getInputs(): List<InputDefinition> = listOf(
7
    InputDefinition(
8
        id = "title", // 参数的唯一ID
9
        name = "标题", // 显示在编辑器中的名称
10
        staticType = ParameterType.STRING, // 参数的基本类型
11
        defaultValue = "vFlow 通知", // 默认值
12
        acceptsMagicVariable = true, // 允许用户连接“魔法变量”
13
        acceptedMagicVariableTypes = setOf(TextVariable.TYPE_NAME) // 只接受文本类型的变量
14
    ),
15
    InputDefinition(
16
        id = "message",
17
        name = "内容",
18
        staticType = ParameterType.STRING,
19
        defaultValue = "这是一条来自 vFlow 的消息。",
20
        acceptsMagicVariable = true,
21
        acceptedMagicVariableTypes = setOf(TextVariable.TYPE_NAME)
22
    )
23
)
24
// ...

1
import com.chaomixian.vflow.core.module.OutputDefinition
2
import com.chaomixian.vflow.core.module.BooleanVariable
3

4
// ...
5
override fun getOutputs(step: ActionStep?): List<OutputDefinition> = listOf(
6
    OutputDefinition(
7
        id = "success", // 输出值的唯一ID
8
        name = "是否成功", // 在魔法变量选择器中显示的名称
9
        typeName = BooleanVariable.TYPE_NAME // 输出值的数据类型
10
    )
11
)
12
// ...

1
import android.content.Context
2
import com.chaomixian.vflow.core.workflow.model.ActionStep
3
import com.chaomixian.vflow.ui.workflow_editor.PillUtil
4

5
// ...
6
override fun getSummary(context: Context, step: ActionStep): CharSequence {
7
    val inputs = getInputs()
8
    val titlePill = PillUtil.createPillFromParam(
9
        step.parameters["title"],
10
        inputs.find { it.id == "title" }
11
    )
12
    val messagePill = PillUtil.createPillFromParam(
13
        step.parameters["message"],
14
        inputs.find { it.id == "message" }
15
    )
16

17
    return PillUtil.buildSpannable(context, "发送通知: ", titlePill, " - ", messagePill)
18
}
19
// ...

1
import android.app.NotificationChannel
2
import android.app.NotificationManager
3
import android.os.Build
4
import androidx.core.app.NotificationCompat
5
import com.chaomixian.vflow.core.execution.ExecutionContext
6
import com.chaomixian.vflow.core.execution.ExecutionResult
7
import com.chaomixian.vflow.core.module.ProgressUpdate
8

9
// ...
10
override suspend fun execute(
11
    context: ExecutionContext,
12
    onProgress: suspend (ProgressUpdate) -> Unit
13
): ExecutionResult {
14
    // 1. 从 ExecutionContext 获取解析后的参数值
15
    // 如果用户连接了魔法变量，它会存在于 magicVariables 中，否则在 variables 中
16
    val title = (context.magicVariables["title"] as? TextVariable)?.value
17
        ?: context.variables["title"] as? String
18
        ?: "vFlow 通知"
19

20
    val message = (context.magicVariables["message"] as? TextVariable)?.value
21
        ?: context.variables["message"] as? String
22
        ?: ""
23

24
    // 2. 报告进度，这对于调试很有帮助
25
    onProgress(ProgressUpdate("准备发送通知: $title"))
26

27
    // 3. 执行核心逻辑
28
    try {
29
        val appContext = context.applicationContext
30
        val notificationManager = appContext.getSystemService(Context.NOTIFICATION_SERVICE) as NotificationManager
31
        val channelId = "vflow_custom_notifications"
32

33
        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
34
            val channel = NotificationChannel(channelId, "自定义通知", NotificationManager.IMPORTANCE_DEFAULT)
35
            notificationManager.createNotificationChannel(channel)
36
        }
37

38
        val notification = NotificationCompat.Builder(appContext, channelId)
39
            .setContentTitle(title)
40
            .setContentText(message)
41
            .setSmallIcon(R.drawable.ic_workflows) // 使用一个已有的图标
42
            .setAutoCancel(true)
43
            .build()
44

45
        notificationManager.notify(System.currentTimeMillis().toInt(), notification)
46

47
        // 4. 返回成功结果，并附带输出值
48
        return ExecutionResult.Success(outputs = mapOf("success" to BooleanVariable(true)))
49

50
    } catch (e: Exception) {
51
        // 5. 如果发生错误，返回失败结果
52
        return ExecutionResult.Failure("执行失败", e.localizedMessage ?: "未知错误")
53
    }
54
}
55
// ...

1
// 文件: .../core/module/ModuleRegistry.kt
2

3
import com.chaomixian.vflow.core.workflow.module.notification.SendNotificationModule // 导入你的新模块
4

5
// ...
6
object ModuleRegistry {
7
    // ...
8
    fun initialize() {
9
        modules.clear()
10
        // ... 其他模块
11

12
        // 应用与系统
13
        register(SendNotificationModule()) // 在这里注册！
14

15
        // ...
16
    }
17
}