| | |
|---|
| | | @Autowired |
|---|
| | | private PackedDataService packedDataService; |
|---|
| | | @Autowired |
|---|
| | | private RedisUtil redisUtil; |
|---|
| | | @Autowired |
|---|
| | | private WorkstationDatapointsService dpService; |
|---|
| | | /** |
|---|
| | | * 处理收到的消息,对应TelemetryDataPostingConsumer |
|---|
| | |
|---|
| | | return dtList; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 根据对应表缓存，获取appId对应的id |
|---|
| | | * @param appId |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | /* |
|---|
| | | public Long getWorkstationIdByAppId(String appId) { |
|---|
| | | |
|---|
| | | Object wid = redisUtil.hget("workstation-appid-map", appId); |
|---|
| | | |
|---|
| | | String workstationId = String.valueOf(Optional.ofNullable(wid).orElse(StringUtils.EMPTY)); |
|---|
| | | if(ObjectUtil.isEmpty(workstationId)) { |
|---|
| | | return null; |
|---|
| | | } |
|---|
| | | return Long.parseLong(workstationId); |
|---|
| | | } |
|---|
| | | */ |
|---|
| | | } |
|---|
