| | |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | | import java.math.BigDecimal; |
| | | import java.util.*; |
| | | import java.util.function.BiConsumer; |
| | | import java.util.function.Function; |
| | | import java.util.stream.Collectors; |
| | | |
| | |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | public Map<String, BigDecimal> selectOfficialAllInfo() { |
| | | // 1. 查询 official_inventory 表数据 |
| | | List<OfficialInventory> officialInventories = officialInventoryMapper.selectList(null); |
| | | |
| | | // 用于存储最终结果,key 为煤种名称,value 为库存数量拼接“吨” |
| | | Map<String, BigDecimal> resultMap = new LinkedHashMap<>(); |
| | | |
| | | // 2. 遍历查询结果,关联 coalInfo 获取煤种名称并组装数据 |
| | | for (OfficialInventory inventory : officialInventories) { |
| | | Long coalId = inventory.getCoalId(); |
| | | // 根据 coalId 到 coalInfoMapper 查询煤种名称 |
| | | CoalInfo coalInfo = coalInfoMapper.selectById(coalId); |
| | | if (coalInfo != null) { |
| | | String coalName = coalInfo.getCoal(); // 假设 CoalInfo 有 getCoalName 方法获取煤种名称 |
| | | BigDecimal quantity = inventory.getInventoryQuantity(); |
| | | resultMap.put(coalName, quantity); |
| | | } |
| | | } |
| | | return resultMap; |
| | | } |
| | | |
| | | } |