| | |
|---|
| | | |
|---|
| | | @Override // org.springblade.modules.mdc.service.ISuperNewCollectService |
|---|
| | | public void insertData(Set<String> workstationIds) { |
|---|
| | | List<NewParamSaveDTO> data = (List) workstationIds.stream().map(workstationId -> { |
|---|
| | | List<NewParamSaveDTO> data = workstationIds.stream().map(workstationId -> { |
|---|
| | | Map<String, Object> realTimeData = WorkstationCache.getWorkstationAllCollect(workstationId); |
|---|
| | | if (Func.isNotEmpty(realTimeData)) { |
|---|
| | | int size = realTimeData.size(); |
|---|
| | | long time = DateUtil.now().getTime(); |
|---|
| | | Map<String, String> valuesMap = new HashMap<>(size); |
|---|
| | | realTimeData.forEach(n, telemetry -> { |
|---|
| | | realTimeData.forEach((n, telemetry) -> { |
|---|
| | | if (!n.toUpperCase().contains(CollectConstant.ALARM)) { |
|---|
| | | TelemetryDataResponseDTO dto = (TelemetryDataResponseDTO) telemetry; |
|---|
| | | String v = dto.getV(); |
|---|
| | |
|---|
| | | return Func.notNull(v0); |
|---|
| | | }).collect(Collectors.toList()); |
|---|
| | | List<List<NewParamSaveDTO>> groupList = CommonUtil.groupList(data, 10); |
|---|
| | | |
|---|
| | | groupList.forEach(this.collectJsonMapper::insertValueJson); |
|---|
| | | /* |
|---|
| | | SuperCollectJsonMapper superCollectJsonMapper = this.collectJsonMapper; |
|---|
| | | superCollectJsonMapper.getClass(); |
|---|
| | | groupList.forEach(this::insertValueJson); |
|---|
| | | groupList.forEach(this::insertValueJson);*/ |
|---|
| | | } |
|---|
| | | } |
|---|
