| | |
| | | |
| | | IntegrationRecord record = new IntegrationRecord( |
| | | String.valueOf(snowflakeIdWorker.nextId()).substring(3), // 编号 |
| | | context.getNamespaceType().name(), // 名称空间 |
| | | context.getNamespaceType().desc, // 名称空间 |
| | | payload.getUri(), // 接口地址 |
| | | request.getHeader(HEADER_APP_KEY), // 平台密钥 |
| | | context.getNamespaceType().caller, // 调用方标识 |
| | |
| | | RCS_BUS_RECEIVE("接收批次任务", Constants.UPLINK), |
| | | ; |
| | | |
| | | public String name; |
| | | public String desc; |
| | | |
| | | public String caller; |
| | | |
| | | NamespaceType(String name, String caller) { |
| | | this.name = name; |
| | | NamespaceType(String desc, String caller) { |
| | | this.desc = desc; |
| | | this.caller = caller; |
| | | } |
| | | |
| | |
| | | |
| | | IntegrationRecord integrationRecord = new IntegrationRecord( |
| | | String.valueOf(snowflakeIdWorker.nextId()).substring(3), // 编号 |
| | | NamespaceType.RCS_TASK_REPORT.name, // 名称空间 |
| | | NamespaceType.RCS_TASK_REPORT.desc, // 名称空间 |
| | | conveyorProperties.getUrl(), // 接口地址 |
| | | null, // 平台密钥 |
| | | Constants.RCS, // 调用方标识 |
| | |
| | | |
| | | IntegrationRecord integrationRecord = new IntegrationRecord( |
| | | String.valueOf(snowflakeIdWorker.nextId()).substring(3), // 编号 |
| | | NamespaceType.RCS_TASK_REPORT.name, // 名称空间 |
| | | NamespaceType.RCS_TASK_REPORT.desc, // 名称空间 |
| | | uplinkProperties.getUrl(), // 接口地址 |
| | | null, // 平台密钥 |
| | | Constants.RCS, // 调用方标识 |