| | |
|---|
| | | // params |
|---|
| | | TaskUplinkParam param = new TaskUplinkParam(); |
|---|
| | | if (null != task.getBusId()) { |
|---|
| | | Bus bus = busService.getById(task); |
|---|
| | | Bus bus = busService.getById(task.getBusId()); |
|---|
| | | param.setBatchNo(bus.getBusNo()); |
|---|
| | | } |
|---|
| | | param.setTaskNo(task.getSeqNum()); |
|---|
| | |
|---|
| | | |
|---|
| | | 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, // 调用方标识 |
|---|
