集成设计器数据流程、流程设计器可以暴露接口触发

集成设计器数据流程暴露接口触发

需求：在集成设计器配置的连接器、数据流程链接到外部接口，需要可以有一个管理页面，统一管理这些集成配置。比如对接多个医院的挂号系统，希望可以配置好数据流程之后，能够在已经实现的开放接口上，动态的调用集成平台配置的数据流程。

连接器暴露接口触发

1. 设计连接器资源配置模型。使用业务ID+接口唯一标识+连接器实现连接器资源和业务唯一。

   @Model.model(EipConnectorResourceSetting.MODEL_MODEL)
   @Model(displayName = "连接器资源配置", summary = "连接器资源配置")
   @Model.Advanced(unique = {"hospitalId, interfaceUnique"})
   public class EipConnectorResourceSetting extends IdModel {
   
   public static final String MODEL_MODEL = "hr.simple.EipConnectorResourceSetting";
   
   @UxTableSearch.FieldWidget(@UxWidget())
   @Field(displayName = "医院", required = true)
   @Field.Relation(relationFields = {"hospitalId"}, referenceFields = {"id"})
   private Hospital hospital;
   
   @Field.Integer
   @Field(displayName = "医院ID", invisible = true)
   private Long hospitalId;
   
   @UxTableSearch.FieldWidget(@UxWidget())
   @Field.String
   @Field(displayName = "接口唯一标识", required = true)
   private String interfaceUnique;
   
   @UxTableSearch.FieldWidget(@UxWidget())
   @Field.many2one
   @Field(displayName = "连接器", required = true)
   @Field.Relation(relationFields = {"connectorId"}, referenceFields = {"id"})
   private EipConnector connector;
   
   @Field.Integer
   @Field(displayName = "连接器ID", invisible = true)
   private Long connectorId;
   
   @UxTableSearch.FieldWidget(@UxWidget())
   @Field.many2one
   @Field(displayName = "连接器接口", required = true)
   @Field.Relation(relationFields = {"integrationInterfaceId"}, referenceFields = {"id"}, domain = "connectorId==${activeRecord.connector.id}")
   private EipConnectorResource connectorResource;
   
   @Field.Integer
   @Field(displayName = "连接器接口ID", invisible = true)
   private Long connectorResourceId;
   }

2. 开放接口定义，文档参考：https://doc.oinone.top/oio4/9326.html
   外部平台调用开放接口，实现动态调用连接器资源

   @Model.model(HospitalSection.MODEL_MODEL)
   @Model(displayName = "医院科室", summary = "医院科室")
   public class HospitalSection extends IdModel {
   
   public static final String MODEL_MODEL = "net.example.HospitalSection";
   
   @Field(displayName = "科室Code", required = true)
   private String deptCode;
   
   @Field(displayName = "科室名称", required = true)
   private String deptName;
   
   @Field(displayName = "科室描述")
   private String deptDesc;
   }

   @Slf4j
   @Fun
   @Component
   public class TestOpenService {
   
   @Resource
   private TestCommonService testCommonService;
   
   @Function
   @Open(name = "获取科室", path = "test/gainSections")
   @Open.Advanced(httpMethod = "POST")
   public OpenEipResult<List<HospitalSection>> gainSections(IEipContext<SuperMap> context, ExtendedExchange exchange) {
       return new OpenEipResult<>(testCommonService.gainSections(context));
   }
   }

   @Slf4j
   @Component
   public class TestCommonService {
   
   @Resource
   private CustomWorkflowService customWorkflowService;
   
   /**
    * 获取科室
    *
    * @param context 请求上下文
    * @return 科室集合
    */
   public List<HospitalSection> gainSections(IEipContext<SuperMap> context) {
       EipResult<SuperMap> gainSections = executeEipConnector(context, "gainSections");
       if (gainSections.getSuccess()) {
           if (gainSections.getContext().getInterfaceContext().get("DepartmentList")!=null) {
               return JSON.parseArray(JSON.toJSONString(gainSections.getContext().getInterfaceContext().get("DepartmentList")),
                       HospitalSection.class);
   
           }
       }
       String errorCode = gainSections.getErrorCode();
       String errorMessage = gainSections.getErrorMessage();
       // Object result = gainSections.getResult();
       return new ArrayList<>();
   }
       /**
    * 根据请求参数中医院id和参数key-value、接口标识获取连接器
    *
    * @param context         请求上下文
    * @param interfaceUnique 接口标识
    * @return 连接器
    */
   private EipResult<SuperMap> executeEipConnector(IEipContext<SuperMap> context, String interfaceUnique) {
       String hospitalId = Optional.ofNullable(String.valueOf(context.getInterfaceContext().getIteration("hospitalId"))).orElse("");
       String parameterValue = Optional.ofNullable(String.valueOf(context.getInterfaceContext().getIteration("parameterValue"))).orElse("");
       //step1. 获取连接器模型
       EipConnectorResourceSetting interfaceSetting = new EipConnectorResourceSetting()
               .setHospitalId(Long.valueOf(hospitalId)).setInterfaceUnique(interfaceUnique).queryOne();
       if (interfaceSetting == null) {
           throw PamirsException.construct(ExpEnumerate.SYSTEM_ERROR).appendMsg("连接器模型未找到").errThrow();
       }
       //step2. 获取连接器接口
       interfaceSetting.fieldQuery(EipConnectorResourceSetting::getConnectorResource);
       EipConnectorResource connectorResource = interfaceSetting.getConnectorResource();
       if (connectorResource == null) {
           throw PamirsException.construct(ExpEnumerate.SYSTEM_ERROR).appendMsg("连接器接口未找到").errThrow();
       }
       //3. 执行连接器获取结果
       Map<String, Object> params = new HashMap<>();
       params.put("wxValue1", parameterValue);
       return EipExecutor.newInstance().call(connectorResource.getInterfaceName(), params);
   }

数据流程暴露接口触发

1. 设计数据流程配置模型。使用业务ID+接口唯一标识+连接器实现数据流程配置和业务唯一。

   @Model.model(EipOpenDataflowSetting.MODEL_MODEL)
   @Model(displayName = "数据流程配置", summary = "数据流程配置")
   @Model.Advanced(unique = {"hospitalId,interfaceUnique"})
   public class EipOpenDataflowSetting extends IdModel {
   
   public static final String MODEL_MODEL = "hr.simple.EipOpenDataflowSetting";
   
   @UxTableSearch.FieldWidget(@UxWidget())
   @Field(displayName = "医院", required = true)
   @Field.Relation(relationFields = {"hospitalId"}, referenceFields = {"id"})
   private Hospital hospital;
   
   @Field.Integer
   @Field(displayName = "医院ID", invisible = true)
   private Long hospitalId;
   
   @UxTableSearch.FieldWidget(@UxWidget())
   @Field.String
   @Field(displayName = "接口唯一标识", required = true)
   private String interfaceUnique;
   
   @UxTableSearch.FieldWidget(@UxWidget())
   @Field.many2one
   @Field(displayName = "数据流程", required = true)
   @Field.Relation(relationFields = {"dataflowId"}, referenceFields = {"id"})
   private DataflowDesigner dataflow;
   
   @Field.Integer
   @Field(displayName = "数据流程编码", invisible = true)
   private Long dataflowId;
   
   @Field.String
   @Field.Related(related = {"dataflow", "code"})
   @UxForm.FieldWidget(@UxWidget(readonly = "true"))
   @Field(displayName = "数据流程编码", store = NullableBoolEnum.TRUE)
   private String dataflowCode;
   }

2. 开放接口定义。

   @Fun(RegisterOpenService.FUN_NAMESPACE)
   public interface RegisterOpenService {
   
   String FUN_NAMESPACE = "net.example.RegisterService";
   
   @Function
   RegisterOrder queryById(Long hospitalId, Long memberId);
   }

   @Slf4j
   @Fun(RegisterOpenService.FUN_NAMESPACE)
   @Component
   public class RegisterOpenServiceImpl implements RegisterOpenService {
   
   @Autowired
   private CustomWorkflowService customWorkflowService;
   
   /**
    * 开放接口：把自己的开放出去供外部调用（如：小程序调用）
    *
    * 文档参考：https://doc.oinone.top/oio4/9326.html
    *
    * 1、接口访问URL地址：http://127.0.0.1:8195/openapi/pamirs/register/queryById 端口根据yml配置进行修改
    * 2、参数默认是map格式，构造为IEipContext对象
    */
   @Function
   @Open(name = "根据ID查询挂号流水", path = "register/queryById")
   @Open.Advanced(
           httpMethod = "GET"
   )
   public OpenEipResult<RegisterOrder> queryById4Open(IEipContext<SuperMap> context, ExtendedExchange exchange) {
       String memberId = Optional.ofNullable(String.valueOf(context.getInterfaceContext().getIteration("id"))).orElse("0");
       String hospitalId = Optional.ofNullable(String.valueOf(context.getInterfaceContext().getIteration("hospitalId"))).orElse("0");
       // 开发接口的内部具体实现
       RegisterOrder register = queryById(Long.valueOf(hospitalId), Long.valueOf(memberId));
       if (register!=null) {
           return new OpenEipResult<>(register);
       } else {
           throw PamirsException.construct(EipExpEnumerate.SYSTEM_ERROR).appendMsg("根据ID "+ memberId +"查询挂号流水").errThrow();
       }
   }
   
   @Override
   @Function
   public RegisterOrder queryById(Long hospitalId, Long memberId) {
       // step1、业务前置逻辑、参数校验等
       // step2、构造请求数据、或者通过BD获取数据（这里先进行Mock）
       RegisterOrder register = new RegisterOrder();
       register.setHospitalId("719331903102009889");
       register.setSectionId("1");
       register.setDoctorId("1");
       register.setSourceId("1");
       register.setPatienterName("zhangsan");
       register.setPatienterIdCard("123444");
       // 配置表，医院 + 接口功能 == >> 流程编码。   ****** 实际项目这些基础数据需要缓存，如果Caffeine/Redis*********
       EipOpenDataflowSetting dataflowSetting = new EipOpenDataflowSetting().setHospitalId(hospitalId).setInterfaceUnique("theWeather").queryOne();
       if (dataflowSetting !=  null) {
           // step3、调用数据流程
           WorkflowDefinition workflowDefinition = customWorkflowService.queryWorkflowDefinition(dataflowSetting.getDataflowCode());
           if (workflowDefinition != null) {
               // 分支1：调用数据流程
               Map<String, Object> result = customWorkflowService.startWorkflow(workflowDefinition, register);
               log.info("调用数据流程返回：" + result);
   
               // 根据返回处理业务逻辑
           }
       } else {
           // 分支2：异常处理，或者没有数据流程实现执行默认逻辑
       }
   
       // Step4 业务后置逻辑，数据操作、其他service的调用之类
       return register;
   }
   }

   @Slf4j
   @Component
   public class CustomWorkflowService {
   
   public WorkflowDefinition queryWorkflowDefinition(String workflowCode) {
       return new WorkflowDefinition().queryOneByWrapper(
               Pops.<WorkflowDefinition>lambdaQuery()
                       .from(WorkflowDefinition.MODEL_MODEL)
                       .eq(WorkflowDefinition::getWorkflowCode, workflowCode)
                       .eq(WorkflowDefinition::getActive, 1)
       );
   }
   
   /**
    * 触发⼯作流实例
    */
   public Map<String, Object> startWorkflow(WorkflowDefinition workflowDefinition, IdModel modelData) {
       Map<String, Object> result = new HashMap<>();
       if (null == workflowDefinition) {
           // 流程没有运⾏实例
           return result;
       }
       String model = Models.api().getModel(modelData);
       //⼯作流上下⽂
       WorkflowDataContext wdc = new WorkflowDataContext();
       wdc.setDataType(WorkflowVariationTypeEnum.ADD);
       wdc.setModel(model);
       wdc.setWorkflowDefinitionDefinition(workflowDefinition.parseContent());
       wdc.setWorkflowDefinition(workflowDefinition);
       wdc.setWorkflowDefinitionId(workflowDefinition.getId());
       IdModel copyData = KryoUtils.get().copy(modelData);
       // ⼿动触发创建的动作流,将操作⼈设置为当前用户,作为流程的发起⼈
       copyData.setCreateUid(PamirsSession.getUserId());
       copyData.setWriteUid(PamirsSession.getUserId());
       String jsonData = JsonUtils.toJSONString(copyData.get_d());
       //触发工作流 新增时触发-onCreateManual 更新时触发-onUpdateManual
       Fun.run(WorkflowModelTriggerFunction.FUN_NAMESPACE, "onCreateManualSync", wdc, "1", jsonData);
   
       // 处理返回结果
       Long workflowInstanceId = (Long) wdc.getDataMap().get(WorkflowConstant.WORKFLOW_INSTANCE_ID);
       if (workflowInstanceId !=null) {
           WorkflowInstance workflowInstance = new WorkflowInstance().setId(workflowInstanceId).queryById();
           WorkflowContext workflowContext = workflowInstance.fetchWorkflowContext();
           result = (HashMap)workflowContext.get(ParamNode.PARAM_PREFIX);
       }
   
       return result;
   }
   
   public Map<String,Object> startCreatOrderWorkflow(WorkflowDefinition workflowDefinition, IdModel modelData){
       Map<String, Object> result = new HashMap<>();
       if (null == workflowDefinition) {
           // 流程没有运⾏实例
           return result;
       }
       String model = Models.api().getModel(modelData);
       //⼯作流上下⽂
       WorkflowDataContext wdc = new WorkflowDataContext();
       wdc.setDataType(WorkflowVariationTypeEnum.ADD);
       wdc.setModel(model);
       wdc.setWorkflowDefinitionDefinition(workflowDefinition.parseContent());
       wdc.setWorkflowDefinition(workflowDefinition);
       wdc.setWorkflowDefinitionId(workflowDefinition.getId());
       IdModel copyData = KryoUtils.get().copy(modelData);
       // ⼿动触发创建的动作流,将操作⼈设置为当前用户,作为流程的发起⼈
       copyData.setCreateUid(PamirsSession.getUserId());
       copyData.setWriteUid(PamirsSession.getUserId());
       String jsonData = JsonUtils.toJSONString(copyData.get_d());
       //触发⼯作流 新增时触发-onCreateManual 更新时触发-onUpdateManual
       Fun.run(WorkflowModelTriggerFunction.FUN_NAMESPACE, "onCreateManualSync", wdc, "1", jsonData);
   
       // 处理返回结果
       Long workflowInstanceId = (Long) wdc.getDataMap().get(WorkflowConstant.WORKFLOW_INSTANCE_ID);
       if (workflowInstanceId !=null) {
           WorkflowInstance workflowInstance = new WorkflowInstance().setId(workflowInstanceId).queryById();
           WorkflowContext workflowContext = workflowInstance.fetchWorkflowContext();
           result = (HashMap)workflowContext.get(ParamNode.PARAM_PREFIX);
       }
   
       return result;
   }
   }