#AI 联动-工作流

public interface FunctionCalling<T extends BaseAiRequest> extends ToolExecutor {
    // 参数校验,子类必须实现
    R checkParams(T t, PigxUser userDetails, ChatMessageDTO.ExtDetails extDetails);

    // 业务处理,子类必须实现
    R<String> handle(T t, PigxUser userDetails, ChatMessageDTO.ExtDetails extDetails);

    // 构建工具规格,供大模型理解函数能力
    default ToolSpecification buildToolSpecification() {
        ToolSpecification.Builder builder = ToolSpecification.builder();
        builder.name(this.functionName());
        builder.description(this.functionDesc());
        Field[] fields = ReflectUtil.getFields(getGenericType());
        builder.parameters(ToolSpecificationsUtils.parametersFrom(fields));
        return builder.build();
    }

    // 预处理逻辑,自动完成上下文设置和参数校验
    default R preHandle(T t) {
        // 1. 验证messageKey
        // 2. 查询聊天记录
        // 3. 设置上下文(租户、用户、token)
        // 4. 调用checkParams校验参数
        // 5. 调用handle执行业务逻辑
    }
}

@Component
@RequiredArgsConstructor
public class FlowFunctionCalling implements FunctionCalling<FlowRequest> {

    private final RemoteFlowApiFlowService flowService;

    // 点击函数卡片后跳转到已发起的流程列表
    @Override
    public String routePath() {
        return "/flow/task/started";
    }

    // 前端展示的函数说明
    @Override
    public String showInfo() {
        return "请假助手,能根据您的描述帮您发起请求流程调用flowable。比如:明天帮我请一天假,好兄弟结婚";
    }

    // 参数校验,当前示例直接返回成功
    @Override
    public R<String> checkParams(FlowRequest request, PigxUser userDetails,
                                  ChatMessageDTO.ExtDetails extDetails) {
        return R.ok();
    }

    // 业务处理:匹配流程并启动
    public R<String> handle(FlowRequest request, PigxUser user,
                            ChatMessageDTO.ExtDetails extDetails) {
        // 获取用户有权限启动的流程列表
        R<List<FormGroupVo>> listR = flowService.listCurrentUserStartGroup();
        if (Objects.isNull(listR.getData())) {
            return R.failed("创建失败,权限不足");
        }

        // 根据流程名称匹配流程ID
        String flowId = "";
        for (FormGroupVo formGroupVo : listR.getData()) {
            for (FormGroupVo.FlowVo item : formGroupVo.getItems()) {
                if (StrUtil.containsAnyIgnoreCase(request.getFlowName(), item.getName())) {
                    flowId = item.getFlowId();
                }
            }
        }

        if (StrUtil.isBlank(flowId)) {
            return R.failed("创建失败,流程不存在");
        }

        // 构建流程启动参数
        ProcessInstanceParamDto processInstanceParamDto = new ProcessInstanceParamDto();
        processInstanceParamDto.setFlowId(flowId);
        processInstanceParamDto.setStartUserId(String.valueOf(user.getId()));

        Map<String, Object> paramMap = new HashMap<>();
        Dict rootUser = Dict.create()
            .set("id", processInstanceParamDto.getStartUserId())
            .set("name", user.getUsername())
            .set("type", NodeUserTypeEnum.USER.getKey());
        paramMap.put("root", CollUtil.newArrayList(rootUser));
        paramMap.put("days", request.getDays());
        paramMap.put("reason", request.getReason());
        paramMap.put("startDate", request.getStartDate());
        processInstanceParamDto.setParamMap(paramMap);

        // 调用Flowable引擎启动流程
        flowService.startProcessInstance(processInstanceParamDto);
        return R.ok(StrUtil.format("流程发起成功,流程名称:{}", request.getFlowName()));
    }
}

@Data
@EqualsAndHashCode(callSuper = true)
@JsonInclude(JsonInclude.Include.NON_NULL)
@JsonClassDescription("流程信息")
class FlowRequest extends BaseAiRequest {
    @FieldPrompt("流程名称:请假流程")
    private String flowName;

    @FieldPrompt("原因:请假原因")
    private String reason;

    @FieldPrompt("天数:请假天数")
    private Integer days;

    @FieldPrompt("开始日期:请假开始日期,格式为 yyyy-MM-dd")
    private String startDate;
}

if (StrUtil.containsAnyIgnoreCase(request.getFlowName(), item.getName())) {
    flowId = item.getFlowId();
}