|
|
@@ -105,9 +105,11 @@ public class BizReasearchQueueClinicServiceImpl extends ServiceImpl<BizReasearch
|
|
|
})
|
|
|
.collect(Collectors.toList());
|
|
|
//手术表中队列数量统计加1
|
|
|
- clinicRoomRepository.update(null,new LambdaUpdateWrapper<BizClinicRoomPO>()
|
|
|
- .setSql("queue_count = queue_count + 1")
|
|
|
- .in(BizClinicRoomPO::getId,clinicIds));
|
|
|
+ if(CollectionUtil.isNotEmpty(clinicIds)){
|
|
|
+ clinicRoomRepository.update(null,new LambdaUpdateWrapper<BizClinicRoomPO>()
|
|
|
+ .setSql("queue_count = queue_count + 1")
|
|
|
+ .in(BizClinicRoomPO::getId,clinicIds));
|
|
|
+ }
|
|
|
this.saveBatch(insertBatch);
|
|
|
insertBatch.parallelStream().forEach(queueClinicPO -> {
|
|
|
rabbitTemplate.convertAndSend(
|
|
|
@@ -138,9 +140,11 @@ public class BizReasearchQueueClinicServiceImpl extends ServiceImpl<BizReasearch
|
|
|
//手术表中队列数量统计减1
|
|
|
List<BizReasearchQueueClinicPO> bizReasearchQueueClinicPOS = baseMapper.selectBatchIds(ids);
|
|
|
List<String> clinicIds = bizReasearchQueueClinicPOS.stream().map(clinic -> clinic.getClinicRoomId()).collect(Collectors.toList());
|
|
|
- clinicRoomRepository.update(null,new LambdaUpdateWrapper<BizClinicRoomPO>()
|
|
|
- .setSql("queue_count = queue_count - 1")
|
|
|
- .in(BizClinicRoomPO::getId,clinicIds));
|
|
|
+ if(CollectionUtil.isNotEmpty(clinicIds)){
|
|
|
+ clinicRoomRepository.update(null,new LambdaUpdateWrapper<BizClinicRoomPO>()
|
|
|
+ .setSql("queue_count = queue_count - 1")
|
|
|
+ .in(BizClinicRoomPO::getId,clinicIds));
|
|
|
+ }
|
|
|
return baseMapper.deleteBatchIds(ids);
|
|
|
}
|
|
|
|