|
@@ -3163,9 +3163,13 @@ public class ApsProcessOperationProcessEquServiceImpl extends ServiceImpl<ApsPro
|
|
this.baseMapper.myDeleteByIds(needDelIdList);
|
|
this.baseMapper.myDeleteByIds(needDelIdList);
|
|
}
|
|
}
|
|
if (req.getNeedSendMessage()) {
|
|
if (req.getNeedSendMessage()) {
|
|
|
|
+ //过滤需要发送消息的数据
|
|
List<ApsDeliveryOffsetDo> needSendMessageList = needUpdateOrInsertList.stream().filter(item -> Arrays.asList("待开工", "加工中").contains(item.getStatus()) && item.getDeliveryoffset() > 0).collect(Collectors.toList());
|
|
List<ApsDeliveryOffsetDo> needSendMessageList = needUpdateOrInsertList.stream().filter(item -> Arrays.asList("待开工", "加工中").contains(item.getStatus()) && item.getDeliveryoffset() > 0).collect(Collectors.toList());
|
|
if (!needSendMessageList.isEmpty()){
|
|
if (!needSendMessageList.isEmpty()){
|
|
|
|
+ for (ApsDeliveryOffsetDo apsDeliveryOffsetDo : needSendMessageList) {
|
|
|
|
+ ProductCardVo productCardVo = list.stream().filter(item -> item.getId().equals(apsDeliveryOffsetDo.getId())).findFirst().orElse(null);
|
|
|
|
|
|
|
|
+ }
|
|
}
|
|
}
|
|
|
|
|
|
}
|
|
}
|