| | |
|---|
| | | import com.github.yulichang.base.MPJBaseServiceImpl; |
|---|
| | | import com.github.yulichang.toolkit.JoinWrappers; |
|---|
| | | import com.github.yulichang.wrapper.MPJLambdaWrapper; |
|---|
| | | import com.google.common.collect.Lists; |
|---|
| | | import com.mes.base.entity.vo.BigStorageVO; |
|---|
| | | import com.mes.bigstorage.entity.BigStorageCage; |
|---|
| | | import com.mes.bigstorage.entity.BigStorageCageDetails; |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public List<BigStorageVO> querybigStorageCageDetail() { |
|---|
| | | return baseMapper.querybigStorageCageDetail(); |
|---|
| | | public Map<Integer, List<BigStorageVO>> querybigStorageCageDetail() { |
|---|
| | | List<BigStorageVO> bigStorageCages = baseMapper.querybigStorageCageDetail(); |
|---|
| | | return bigStorageCages.stream().collect(Collectors.groupingBy(item -> item.getDeviceId())); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public boolean cancelTemperingTask() { |
|---|
| | | return false; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | |
|---|
| | | .orderByAsc(BigStorageCageDetails::getTemperingFeedSequence) |
|---|
| | | ); |
|---|
| | | if (CollectionUtils.isNotEmpty(temperingGlassInfos)) { |
|---|
| | | temperingGlassInfoService.saveBatch(temperingGlassInfos); |
|---|
| | | //避免大量数据插入导致sqlserver数据库异常，分批次每调存储依次 |
|---|
| | | List<List<TemperingGlassInfo>> temperingGlassInfoLists = Lists.partition(temperingGlassInfos, 50); |
|---|
| | | for (List<TemperingGlassInfo> item : temperingGlassInfoLists) { |
|---|
| | | temperingGlassInfoService.saveBatch(item); |
|---|
| | | } |
|---|
| | | return true; |
|---|
| | | } |
|---|
| | | } |
|---|
