| | |
| | | import com.qianwen.smartman.common.constant.DateConstant; |
| | | import com.qianwen.smartman.common.constant.VisualConstant; |
| | | import com.qianwen.core.tool.utils.DateUtil; |
| | | import com.qianwen.smartman.modules.cps.entity.Workstation; |
| | | import com.qianwen.smartman.modules.smis.entity.Workstation; |
| | | import com.qianwen.smartman.modules.mdc.entity.SuperAggregateOutput; |
| | | import com.qianwen.smartman.modules.system.entity.SeriesItem; |
| | | import com.qianwen.smartman.modules.system.vo.ChartSeriesDataVO; |
| | |
| | | return v0.getWorkstationId(); |
| | | })).forEach((id, aggregateOutputs) -> { |
| | | Map<String, Long> collectMap = aggregateOutputs.stream().collect(Collectors.groupingBy(aggregate -> { |
| | | return (String) categoriesFormat.apply(aggregate.getTs().toLocalDateTime()); |
| | | return (String) categoriesFormat.apply(aggregate.getTime().toLocalDateTime()); |
| | | }, Collectors.summingLong((v0) -> { |
| | | return v0.getOutput(); |
| | | }))); |